Sean Quah created KAFKA-18200:
---------------------------------
Summary: New coordinator can flush an empty batch if append fails
Key: KAFKA-18200
URL: https://issues.apache.org/jira/browse/KAFKA-18200
Project: Kafka
Issue Type: Bug
Components: group-coordinator
Reporter: Sean Quah
When serialization of records fails in {{{}CoordinatorRuntime.append{}}}, the
exception is not caught and we can leave an empty batch around. After the
linger time elapses, we try to flush it and {{PartitionWriter.append()}}
returns 0 instead of the usual offset. {{SnapshottableCoordinator}} throws an
exception when we try to update the last written offset.
{code:java}
java.lang.IllegalStateException: New last written offset 0 of
__consumer_offsets-1 must be greater than 5.
at
org.apache.kafka.coordinator.common.runtime.SnapshottableCoordinator.updateLastWrittenOffset(SnapshottableCoordinator.java:143)
{code}
Luckily this error is handled and the empty batch is failed and removed, so the
coordinator does not get stuck.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
