NEW QUESTION 1
We want the average of all events in every five-minute window updated every minute. What kind of Kafka Streams window will be required on the stream?

• A. Session window
• B. Tumbling window
• C. Sliding window
• D. Hopping window

Answer: D

Explanation:
A hopping window is defined by two propertiesthe window's size and its advance interval (aka "hop"), e.g., a hopping window with a size 5 minutes and an advance interval of 1 minute.

NEW QUESTION 2
You want to perform table lookups against a KTable everytime a new record is received from the KStream. What is the output of KStream-KTable join?

• A. KTable
• B. GlobalKTable
• C. You choose between KStream or KTable
• D. Kstream

Answer: D

Explanation:
Here KStream is being processed to create another KStream.

NEW QUESTION 3
In Avro, removing a field that does not have a default is a schema evolution

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

Answer: C

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

NEW QUESTION 4
CORRECT TEXT
If I want to send binary data through the REST proxy to topic "test_binary", it needs to be base64 encoded. A consumer connecting directly into the Kafka topic

• A. "test_binary" will receive
• B. binary data
• C. avro data
• D. json data
• E. base64 encoded data, it will need to decode it

Answer: B

Explanation:
On the producer side, after receiving base64 data, the REST Proxy will convert it into bytes and then send that bytes payload to Kafka. Therefore consumers reading directly from Kafka will receive binary data.

NEW QUESTION 5
How does a consumer commit offsets in Kafka?

• A. It directly sends a message to the consumer_offsets topic
• B. It interacts with the Group Coordinator broker
• C. It directly commits the offsets in Zookeeper

Answer: B

Explanation:
Consumers do not directly write to the consumer_offsets topic, they instead interact with a broker that has been elected to manage that topic, which is the Group Coordinator broker

NEW QUESTION 6
Your producer is producing at a very high rate and the batches are completely full each
time. How can you improve the producer throughput? (select two)

• A. Enable compression
• B. Disable compression
• C. Increase batch.size
• D. Decrease batch.size
• E. Decrease linger.ms Increase linger.ms

Answer: AC

Explanation:
batch.size controls how many bytes of data to collect before sending messages to the Kafka broker. Set this as high as possible, without exceeding available memory. Enabling compression can also help make more compact batches and increase the throughput of your producer. Linger.ms will have no effect as the batches are already full

NEW QUESTION 7
A kafka topic has a replication factor of 3 and min.insync.replicas setting of 1. What is the maximum number of brokers that can be down so that a producer with acks=all can still produce to the topic?

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

Answer: C

Explanation:
Two brokers can go down, and one replica will still be able to receive and serve data

NEW QUESTION 8
What happens if you write the following code in your producer? producer.send(producerRecord).get()

• A. Compression will be increased
• B. Throughput will be decreased
• C. It will force all brokers in Kafka to acknowledge the producerRecord
• D. Batching will be increased

Answer: B

Explanation:
Using Future.get() to wait for a reply from Kafka will limit throughput.

NEW QUESTION 9
There are 3 producers writing to a topic with 5 partitions. There are 5 consumers consuming from the topic. How many Controllers will be present in the cluster?

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

Answer: D

Explanation:
There is only one controller in a cluster at all times.

NEW QUESTION 10
Where are the dynamic configurations for a topic stored?

• A. In Zookeeper
• B. In an internal Kafka topic topic_configuratins
• C. In server.properties
• D. On the Kafka broker file system

Answer: A

Explanation:
Dynamic topic configurations are maintained in Zookeeper.

NEW QUESTION 11
There are 3 brokers in the cluster. You want to create a topic with a single partition that is resilient to one broker failure and one broker maintenance. What is the replication factor will you specify while creating the topic?

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

Answer: B

Explanation:
1 is not possible as it doesn't provide resilience to failure, 2 is not enough as if we take a broker down for maintenance, we cannot tolerate a broker failure, and 6 is impossible as we only have 3 brokers (RF cannot be greater than the number of brokers). Here the correct answer is 3

NEW QUESTION 12
I am producing Avro data on my Kafka cluster that is integrated with the Confluent Schema Registry. After a schema change that is incompatible, I know my data will be rejected. Which component will reject the data?

• A. The Confluent Schema Registry
• B. The Kafka Broker
• C. The Kafka Producer itself
• D. Zookeeper

Answer: A

Explanation:
The Confluent Schema Registry is your safeguard against incompatible schema changes and will be the component that ensures no breaking schema evolution will be possible. Kafka Brokers do not look at your payload and your payload schema, and therefore will not reject data

NEW QUESTION 13
Partition leader election is done by

• A. The consumers
• B. The Kafka Broker that is the Controller
• C. Zookeeper
• D. Vote amongst the brokers

Answer: C

Explanation:
The Controller is a broker that is responsible for electing partition leaders

NEW QUESTION 14
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 15
To get acknowledgement of writes to only the leader partition, we need to use the config...

• A. acks=1
• B. acks=0
• C. acks=all

Answer: A

Explanation:
Producers can set acks=1 to get acknowledgement from partition leader only.

NEW QUESTION 16
What is the disadvantage of request/response communication?

• A. Scalability
• B. Reliability
• C. Coupling
• D. Cost

Answer: C

Explanation:
Point-to-point (request-response) style will couple client to the server.

NEW QUESTION 17
......