kafka-consumer - Gopi Gorantala

Kafka CorruptRecordException: Record Is Corrupt — Fix It

Kafka CorruptRecordException: Record is corrupt (stored crc != computed crc). Why the CRC check fails, how to recover the partition, and how to stop it recurring.

Kafka InstanceAlreadyExistsException: AppInfo Mbean Fix

Kafka logs 'Error registering AppInfo mbean javax.management.InstanceAlreadyExistsException'. Here's what a duplicate client.id really breaks and how to fix it.

Kafka Timeout Before Position for Partition Could Be Determined

Kafka consumer failing with TimeoutException: Timeout of 60000ms expired before the position for partition could be determined? Here's the fix.

Kafka: Subscription to Topics, Partitions and Pattern Are Mutually Exclusive

Kafka throws IllegalStateException: Subscription to topics, partitions and pattern are mutually exclusive when you mix subscribe() and assign(). Here's the fix.

Kafka UnknownMemberIdException: Why It Happens and How to Fix It

Kafka UnknownMemberIdException — 'The coordinator is not aware of this member' (code 25). Learn the three triggers, the memberId lifecycle, and the exact fix.

Kafka OffsetOutOfRangeException: auto.offset.reset Explained

Fix OffsetOutOfRangeException and NoOffsetForPartitionException in Kafka: why committed offsets vanish, what auto.offset.reset really does, and safe resets.

Kafka "Failed to construct kafka consumer": Every Cause, Fixed

KafkaException: Failed to construct kafka consumer — how to triage every common cause (deserializer class, classpath, DNS, JAAS, SSL) and fix each one fast.

Kafka SerializationException: Fixing Poison Pill Records

Kafka SerializationException: "Error deserializing key/value" crashes your consumer in a loop. Fix it with ErrorHandlingDeserializer and a dead letter topic.

Kafka FETCH_SESSION_ID_NOT_FOUND: Causes and Fix

Kafka logs spamming FETCH_SESSION_ID_NOT_FOUND or INVALID_FETCH_SESSION_EPOCH? Here's what the fetch session cache is doing and how to stop the noise.

Kafka InvalidGroupIdException: Fixing the group.id Error

Hitting InvalidGroupIdException: "you must provide a valid group.id"? Why subscribe() and offset commits require a group.id in Kafka, and the exact fix.