View all questions & answers for the CCDAK exam
How can you gracefully make a Kafka consumer to stop immediately polling data from Kafka and gracefully shut down a consumer application?
Call consumer.wakeUp() and catch a WakeUpException
Call consumer.poll() in another thread
Kill the consumer thread
See https://stackoverflow.com/a/37748336/3019499
Submit