Kafka - Consumers
You want to process messages from multiple Kafka topics continuously and commit offsets manually after processing. Which code snippet correctly implements this using a consumer poll loop?
You want to process messages from multiple Kafka topics continuously and commit offsets manually after processing. Which code snippet correctly implements this using a consumer poll loop?
hard📝 Application Q15 of 15
Step-by-Step Solution
Solution:
Step 1: Check poll argument and loop structure
while(true) { var records = consumer.poll(Duration.ofMillis(200)); for(var record : records) { process(record); } consumer.commitSync(); } usespoll(Duration.ofMillis(200))inside a continuouswhile(true)loop, which is correct.Step 2: Verify message processing and manual commit
It processes each record and callscommitSync()after processing, ensuring offsets are committed manually.Final Answer:
while(true) { var records = consumer.poll(Duration.ofMillis(200)); for(var record : records) { process(record); } consumer.commitSync(); } -> Option CQuick Check:
Continuous poll, process, then manual commit [OK]
Quick Trick: Use while(true), poll with Duration, then commitSync() [OK]
Common Mistakes:
- Passing int instead of Duration to poll()
- Using for loop instead of continuous loop
- Not processing records before commit
- Missing loop causing single poll only
Master "Consumers" in Kafka
Want More Practice?
15+ quiz questions · All difficulty levels · Free
Free Signup - Practice All QuestionsMore Kafka Quizzes