kafka-go

kafka-go copied to clipboard

**Describe the bug** > When the same consumer group subscribes to different topics, the leader cannot monitor the partition changes of another topic. **Kafka Version** > * 2.8 > *...

fzj55

fetchMessage receive some empty message

1

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

sunxiatao

fix: #429 respin making reader.read respect context closure

5

fix: #428 This is a respin of #429 with added benchmarks like the review asked for. ``` MAIN BenchmarkReaderClose-14 1 1001178125 ns/op 55016 B/op 429 allocs/op Branch BenchmarkReaderClose-14 1 1001329375...

zekth