kafka-docker - Gopi Gorantala

Kafka Failed to Acquire Lock on File .lock: How to Fix It

Kafka broker won't start: 'Failed to acquire lock on file .lock ... A Kafka instance in another process is using this directory.' Why it happens 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: 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.

Kafka: Connection Terminated During Authentication — Fix

Kafka AuthenticationException 'terminated during authentication' with its three-reason hint decoded: security.protocol mismatch, TLS/firewall, and mTLS. Repro plus the fix.

Kafka InitProducerId Timeout: Why It Hangs and the Fix

Kafka producer throws 'Timeout expired after 60000ms while awaiting InitProducerId' and initTransactions() hangs on startup. Here's the real root cause and 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 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.

KafkaStorageException: Disk Error & No Space Left on Device

Fix org.apache.kafka.common.errors.KafkaStorageException and 'No space left on device' broker shutdowns — recovery runbook, retention math, disk sizing.

Kafka Streams MissingSourceTopicException: Fix It Fast

Kafka Streams dies with MissingSourceTopicException on startup or rebalance. Here's why the assignor flags a missing source topic and how to fix it.