spring-kafka - Gopi Gorantala

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 TransactionalIdAuthorizationException: Fix the ACL

TransactionalIdAuthorizationException: Transactional Id authorization failed. Why your EOS/Spring transactional producer dies on a secured cluster and the exact ACLs that fix 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.

Kafka TopicAuthorizationException: Not Authorized to Access Topics — Fix

Hitting TopicAuthorizationException: Not authorized to access topics in Kafka? Here's why ACLs deny you, how principals really resolve, and the exact fix.

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 SSL Handshake Failed: PKIX and Hostname Fixes

Fix org.apache.kafka.common.errors.SslAuthenticationException: SSL handshake failed — PKIX path errors, SAN mismatches, and listener protocol mixups 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 SerializationException: Schema Not Found (40403) Fix

Kafka consumer dies with SerializationException: Error retrieving Avro schema for id N, Schema not found; error code: 40403. Why the ID lookup fails and how to fix it.

Kafka SaslAuthenticationException: Authentication Failed — Fix

Getting SaslAuthenticationException: Authentication failed in Kafka? Fix invalid SASL credentials, JAAS config, and missing SCRAM users with working examples.