segmentio / kafka-go

Kafka library in Go
MIT License
7.64k stars 792 forks source link

fetchMessage receive some empty message #1348

Open sunxiatao opened 1 week ago

sunxiatao commented 1 week ago

When consuming messages using Kafka's FetchMessage in a consumer group, each message is followed by an unexpected message with a length of 6 and a value consisting of six \u0000 characters (null characters). These "empty" messages do not exist in the topic, which suggests there may be an issue with how the kafka-go consumer is handling message offsets or fetching messages.

kafka version: kafka_2.12-3.8.0 kafka-go version: v0.4.47

flashmouse commented 4 days ago

I think you may have interest investigate these discussion #414 and #216