kafka-go
kafka-go copied to clipboard
segmentio
Kafka library in Go
**Describe the bug** When using Kafka Reader to read messages from kafka with StartOffset set to last offset and group id was never used before the Reader just doesn't read...
**Describe the bug** >ReadMessage ends up in a loop and does not return when kafka broker gets deleted **Kafka Version** > * What version(s) of Kafka are you testing against?...
**Describe the bug** > A clear and concise description of what the bug is. The Kafka message too large error can not be asserted via `errors.Is` **Kafka Version** > *...
I filed this ticket in the confluent library- https://github.com/confluentinc/confluent-kafka-go/issues/1193 is this a limitation of the Confluent SDK or with the Kafka API..or? need insight ty ty
I stumbled across #874 and dug in. The issue seems to be caused by the fact readMessageV2 expects a message to be present on the wire, but a compacted topic...
Hi there, wondering if it is possible to create multiple readers/consumers? ~From this issue https://github.com/segmentio/kafka-go/issues/1200 it looks like only 1 reader is possible, but I couldn't find where in the...
**Describe the bug** The round robin balancer seems to not be balancing on a per topic basis and instead balances between partitions across all topics messages are enqueued for, ignoring...
Most likely it is not a feature request, but a question. How can I control Grouped Consumer failover from the rebooted/broken broker (group coordinator) to another broker within the cluster?...
the confluent library has this limitation: https://github.com/confluentinc/confluent-kafka-go/issues/1193 can the segmentio library mitigate this?
Is it possible to specify the number of items for one-time consumption and reduce IO frequency?
