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-consumer
19 PostsKafka 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: Assignments Can Only Be Reset If the Group Is Inactive
Kafka's reset-offsets fails with 'Assignments can only be reset if the group is inactive, but the current state is Stable.' Here's why, and the fix.
Kafka RebalanceInProgressException: Why It Happens and How to Fix It
Kafka RebalanceInProgressException on commitSync/commitAsync with CooperativeStickyAssignor? Here's why it's not CommitFailedException, and the correct 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 IllegalStateException: No Current Assignment for Partition
Getting java.lang.IllegalStateException: No current assignment for partition on seek()? Why Kafka's lazy assignment causes it — and the correct fix.
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.
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: Marking the Coordinator Dead — Causes and Fix
Kafka consumer stuck logging 'Marking the coordinator dead' / 'Group coordinator is unavailable or invalid, will attempt rediscovery'. Here's the real cause and the fix.