event-streaming - Gopi Gorantala

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 FencedInstanceIdException: Fix Static Membership Collisions

FencedInstanceIdException means two live consumers share one group.instance.id. Here's why the broker fences the old one, and how to fix it for good.

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: Consumer Is Not Subscribed to Any Topics — Fix

IllegalStateException: Consumer is not subscribed to any topics or assigned any partitions — why poll() throws it, the subscribe/assign contract, and the fix.

Fix KafkaConsumer Is Not Safe for Multi-Threaded Access

Hitting ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access? Here's why the thread guard fires and the correct fix.

Kafka Connect Task Threw an Uncaught and Unrecoverable Exception

Kafka Connect task killed with 'uncaught and unrecoverable exception'? It's usually a converter poison pill. Here's the DataException root cause, DLQ fix, and design.

Kafka Connect Failed to Flush: Offset Commit Timeout Fix

Kafka Connect source task logs 'Failed to flush, timed out while waiting for producer to flush outstanding N messages'. Here's the real cause and the fix.

Kafka Connect: Failed to Find Any Class That Implements Connector

Kafka Connect throws 'Failed to find any class that implements Connector' when plugin.path is wrong or classloader isolation hides your JAR. Here's the fix.

Kafka: Cannot Perform Operation After Producer Closed

Kafka IllegalStateException 'Cannot perform operation after producer has been closed' explained: why it happens, the Spring share