Confluent Certified Developer for Apache Kafka Certification Examination: CCDAK

You are doing complex calculations using a machine learning framework on records fetched from a Kafka topic. It takes more about 6 minutes to process a record batch, and the consumer enters rebalances even though it's still running. How can you improve this scenario?

A. Increase max.poll.interval.ms to 600000

B. Increase heartbeat.interval.ms to 600000

C. Increase session.timeout.ms to 600000

D. Add consumers to the consumer group and kill them right away

A client connects to a broker in the cluster and sends a fetch request for a partition in a topic. It gets an exception Not Leader For Partition Exception in the response. How does client handle this situation?

A. Get the Broker id from Zookeeper that is hosting the leader replica and send request to it

B. Send metadata request to the same broker for the topic and select the broker hosting the leader replica

C. Send metadata request to Zookeeper for the topic and select the broker hosting the leader replica

D. Send fetch request to each Broker in the cluster

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