NEW QUESTION 1
What client protocol is supported for the schema registry? (select two)

• A. HTTP
• B. HTTPS
• C. JDBC
• D. Websocket
• E. SASL

Answer: AB

Explanation:
clients can interact with the schema registry using the HTTP or HTTPS interface

NEW QUESTION 2
A producer application was sending messages to a partition with a replication factor of 2 by connecting to Broker 1 that was hosting partition leader. If the Broker 1 goes down, what will happen?

• A. The producer will automatically produce to the broker that has been elected leader
• B. The topic will be unavailable
• C. The producer will stop working

Answer: A

Explanation:
Once the client connects to any broker, it is connected to the entire cluster and in case of leadership changes, the clients automatically do a Metadata Request to an available broker to find out who is the new leader for the topic. Hence the producer will automatically keep on producing to the correct Kafka Broker

NEW QUESTION 3
You have a consumer group of 12 consumers and when a consumer gets killed by the process management system, rather abruptly, it does not trigger a graceful shutdown of your consumer. Therefore, it takes up to 10 seconds for a rebalance to happen. The business would like to have a 3 seconds rebalance time. What should you do? (select two)

• A. Increase session.timeout.ms
• B. Decrease session.timeout.ms
• C. Increase heartbeat.interval.ms
• D. decrease max.poll.interval.ms
• E. increase max.poll.interval.ms
• F. Decrease heartbeat.interval.ms

Answer: BE

Explanation:
session.timeout.ms must be decreased to 3 seconds to allow for a faster rebalance, and the heartbeat thread must be quicker, so we also need to decrease heartbeat.interval.ms

NEW QUESTION 4
By default, which replica will be elected as a partition leader? (select two)

• A. Preferred leader broker if it is in-sync and auto.leader.rebalance.enable=true
• B. Any of the replicas
• C. Preferred leader broker if it is in-sync and auto.leader.rebalance.enable=false
• D. An in-sync replica

Answer: BD

Explanation:
Preferred leader is a broker that was leader when topic was created. It is preferred because when partitions are first created, the leaders are balanced between brokers. Otherwise, any of the in-sync replicas (ISR) will be elected leader, as long as unclean.leader.election=false (by default)

NEW QUESTION 5
A producer just sent a message to the leader broker for a topic partition. The producer used acks=1 and therefore the data has not yet been replicated to followers. Under which conditions will the consumer see the message?

• A. Right away
• B. When the message has been fully replicated to all replicas
• C. Never, the produce request will fail
• D. When the high watermark has advanced

Answer: D

Explanation:
The high watermark is an advanced Kafka concept, and is advanced once all the ISR replicates the latest offsets. A consumer can only read up to the value of the High Watermark (which can be less than the highest offset, in the case of acks=1)

NEW QUESTION 6
Select all that applies (select THREE)

• A. min.insync.replicas is a producer setting
• B. acks is a topic setting
• C. acks is a producer setting
• D. min.insync.replicas is a topic setting
• E. min.insync.replicas matters regardless of the values of acks
• F. min.insync.replicas only matters if acks=all

Answer: CDF

Explanation:
acks is a producer setting min.insync.replicas is a topic or broker setting and is only effective when acks=all

NEW QUESTION 7
In Kafka, every broker... (select three)

• A. contains all the topics and all the partitions
• B. knows all the metadata for all topics and partitions
• C. is a controller
• D. knows the metadata for the topics and partitions it has on its disk
• E. is a bootstrap broker
• F. contains only a subset of the topics and the partitions

Answer: BEF

Explanation:
Kafka topics are divided into partitions and spread across brokers. Each brokers knows about all the metadata and each broker is a bootstrap broker, but only one of them is elected controller

NEW QUESTION 8
To import data from external databases, I should use

• A. Confluent REST Proxy
• B. Kafka Connect Sink
• C. Kafka Streams
• D. Kafka Connect Source

Answer: D

Explanation:
Kafka Connect Sink is used to export data from Kafka to external databases and Kafka
Connect Source is used to import from external databases into Kafka.

NEW QUESTION 9
You are using JDBC source connector to copy data from 2 tables to two Kafka topics. There is one connector created with max.tasks equal to 2 deployed on a cluster of 3 workers. How many tasks are launched?

• A. 6
• B. 1
• C. 2
• D. 3

Answer: C

Explanation:
we have two tables, so the max number of tasks is 2

NEW QUESTION 10
To enhance compression, I can increase the chances of batching by using

• A. acks=all
• B. linger.ms=20
• C. batch.size=65536
• D. max.message.size=10MB

Answer: B

Explanation:
linger.ms forces the producer to wait before sending messages, hence increasing the chance of creating batches that can be heavily compressed.

NEW QUESTION 11
The kafka-console-consumer CLI, when used with the default options

• A. uses a random group id
• B. always uses the same group id
• C. does not use a group id

Answer: A

Explanation:
If a group is not specified, the kafka-console-consumer generates a random consumer group.

NEW QUESTION 12
In Avro, adding a field to a record without default is a schema evolution

• A. forward
• B. backward
• C. full
• D. breaking

Answer: A

Explanation:
Clients with old schema will be able to read records saved with new schema.

NEW QUESTION 13
What isn't a feature of the Confluent schema registry?

• A. Store avro data
• B. Enforce compatibility rules
• C. Store schemas

Answer: A

Explanation:
Data is stored on brokers.

NEW QUESTION 14
You have a Kafka cluster and all the topics have a replication factor of 3. One intern at your company stopped a broker, and accidentally deleted all the data of that broker on the disk. What will happen if the broker is restarted?

• A. The broker will start, and other topics will also be deleted as the broker data on the disk got deleted
• B. The broker will start, and won't be online until all the data it needs to have is replicated from other leaders
• C. The broker will crash
• D. The broker will start, and won't have any dat
• E. If the broker comes leader, we have a data loss

Answer: B

Explanation:
Kafka replication mechanism makes it resilient to the scenarios where the broker lose data on disk, but can recover from replicating from other brokers. This makes Kafka amazing!

NEW QUESTION 15
Which actions will trigger partition rebalance for a consumer group? (select three)

• A. Increase partitions of a topic
• B. Remove a broker from the cluster
• C. Add a new consumer to consumer group
• D. A consumer in a consumer group shuts down Add a broker to the cluster

Answer: ACD

Explanation:
Rebalance occurs when a new consumer is added, removed or consumer dies or paritions increased.

NEW QUESTION 16
What is not a valid authentication mechanism in Kafka?

• A. SASL/GSSAPI
• B. SASL/SCRAM
• C. SAML
• D. SSL

Answer: C

Explanation:
Learn more about security herehttps://kafka.apache.org/documentation/#security

NEW QUESTION 17
Where are KSQL-related data and metadata stored?

• A. Kafka Topics
• B. Zookeeper
• C. PostgreSQL database
• D. Schema Registry

Answer: A

Explanation:
metadata is stored in and built from the KSQL command topic. Each KSQL server has its own in-memory version of the metastore.

NEW QUESTION 18
......