To enhance compression, I can increase the chances of batching by using
Correct Answer:B
linger.ms forces the producer to wait before sending messages, hence increasing the chance of creating batches that can be heavily compressed.
What happens when broker.rack configuration is provided in broker configuration in Kafka cluster?
Correct Answer:C
Partitions for newly created topics are assigned in a rack alternating manner, this is the only change broker.rack does
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)
Correct Answer:BE
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
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?
Correct Answer:B
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!
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?
Correct Answer:D
Here KStream is being processed to create another KStream.