kafka-go
kafka-go copied to clipboard
segmentio
Kafka library in Go
The comments of FetchMessage state that when io.EOF is returned, it means that the reader has been closed. However, I encountered a scenario where the reader did not closed and...
**Describe the bug** When there are 2 consumers with the same group ID attempting to consume from different topics and one of them is consuming from a topic that does...
If current consumer group leader down , will trigger rebalance, but before a new leader is elected, findCoordinator still returns the old leader，rebalance will fail . * Unable to establish...
**Describe the bug** Reader doesn't fetch messages after new consumer group creation when `StartOffset` is set to `FirstOffset` **Kafka Version** > * What version(s) of Kafka are you testing against?...
AlterConfigs request was always sent to controller, but when trying to update a broker config, it must be sent to corresponding broker.
**Describe the bug** Giving an empty resource value in AlterConfigs in order to reset a topic config entry returns an error. **Kafka Version** Kafka 2.4.1 and 3.4.0, kafka-go 0.4.43. **To...
**Describe the bug** We're using the library across hundreds of instances reading from a Kafka cluster. And the rate of this ErrNoProgress errors is alarmingly high, at around 10/s across...
Fixes [issue-1188](https://github.com/segmentio/kafka-go/issues/1188) and drastically reduce the number of reader errors and dials. Across a couple hundred reader instances, we saw the number of reader errors drop from a couple hundred...
The benefit of initializing the slice with max batch size as the capacity is minimum compared to the downside - in applications that uses large max batch size but writes...