spring-kafka

35 Posts

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 SaslAuthenticationException: Authentication Failed — Fix

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

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 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 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.

Kafka RetriableCommitFailedException: Causes and Fix

Kafka RetriableCommitFailedException on offset commit means a transient commit failure you must retry yourself. Here's what triggers it and how to handle it correctly.

Kafka InconsistentGroupProtocolException: Cause and Fix

Kafka InconsistentGroupProtocolException: the group member's supported protocols are incompatible. Why it hits mid-upgrade and how to fix the assignor mismatch.

Kafka InvalidTxnStateException: Causes and How to Fix It

InvalidTxnStateException means your producer called a transactional API in the wrong state. Here's the state machine, the exact triggers, and the fix.

Kafka InvalidTopicException: Why It Happens and How to Fix It

Kafka InvalidTopicException — 'Topic name is illegal' from bad characters, 249-char limits, or '.'/'_' collisions. The exact rules, root cause, and the fix.