[Solved] Identify the error in this Kafka consumer offset commit code snippet:consumer.commitSync(Collections.singletonMap( new TopicPartition("topic1", 0), new OffsetAndMetadata(5) )); | Kafka

Kafka - Consumers

Identify the error in this Kafka consumer offset commit code snippet:

consumer.commitSync(Collections.singletonMap(
  new TopicPartition("topic1", 0),
  new OffsetAndMetadata(5)
));

AOffsetAndMetadata requires timestamp parameter

BTopicPartition is missing partition number

CcommitSync does not accept a map argument

DOffset should be 6 to commit next message

Step-by-Step Solution

Solution:

Step 1: Understand offset commit semantics
Offsets are zero-based; committing offset 5 means next message to read is offset 5, so to commit up to message 5, offset should be 6.
Step 2: Check method usage and parameters
commitSync accepts a map with TopicPartition and OffsetAndMetadata; TopicPartition is correctly specified; OffsetAndMetadata does not require timestamp.
Final Answer:
Offset should be 6 to commit next message -> Option D
Quick Check:
Commit offset = next message offset [OK]

Quick Trick: Commit offset = next message to read, not last processed [OK]

Common Mistakes:

Master "Consumers" in Kafka

9 interactive learning modes - each teaches the same concept differently

More Kafka Quizzes

Identify the error in this Kafka consumer offset commit code snippet: