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.
event-streaming
29 PostsKafka: Timed out waiting for a node assignment — Fix
Kafka AdminClient and kafka-topics.sh fail with 'Timed out waiting for a node assignment. Call: createTopics'. Here's why it happens and the exact fix.
Kafka Streams LockException: Failed to Lock the State Directory
Kafka Streams throwing LockException: Failed to lock the state directory for task? Here's the exact cause, why it happens, and the fix.
Featured
Kafka TimeoutException: Expiring N record(s) — Cause and Fix
Kafka producer failing with TimeoutException: Expiring N record(s): ms has passed since batch creation? What delivery.timeout.ms really does — and 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 LEADER_NOT_AVAILABLE: Why It Happens and How to Fix It
Kafka LEADER_NOT_AVAILABLE floods your producer logs the moment you write to a fresh topic. Here's the exact cause, the reproduction, and the real 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 Streams: A Serializer Is Not Compatible to the Actual Type
Kafka Streams throws 'A serializer is not compatible to the actual key or value type' or 'ClassCastException invoking Processor'. Here's the SerDe fix.
Kafka Streams TaskCorruptedException: Fix and Prevent It
Kafka Streams TaskCorruptedException wipes local state and re-restores from the changelog. Here's why it fires under EOS, how to fix it, and how to stop it.
Kafka TopicExistsException: Why It Happens and How to Fix It
Kafka TopicExistsException: Topic 'X' already exists. Why AdminClient, Spring KafkaAdmin, and kafka-topics.sh throw it, and how to handle it idempotently.