How can you improve this scenario?

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 he 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

Answer: A

Explanation:

Here, we need to change the setting max.poll.interval.ms (default 300000) to its double in order to tell Kafka a consumer should be considered dead if the consumer only if it hasn’t called the .poll() method in 10 minutes instead of 5.