kafka-go
kafka-go copied to clipboard
segmentio
Kafka library in Go
The base offset was always 0 before but probably should be the offset of the first record.
This PR does not change anything for the existing functions but simply appending a new function to cover requirements like: #852 #326 #707 New fuction is called "WriteMessageGroup" because user...
**Describe the solution you would like** In version 2.4.0, Kafka introduced the ability for consumers to fetch data from a replica instead of a partition leader. While we already support...
It would be great to use this feature: https://cwiki.apache.org/confluence/display/KAFKA/KIP-429%3A+Kafka+Consumer+Incremental+Rebalance+Protocol I believe it is supported in other clients: https://pkg.go.dev/github.com/Shopify/sarama#StickyBalanceStrategyName https://pkg.go.dev/github.com/twmb/franz-go/pkg/kgo#CooperativeStickyBalancer But I couldn't find it in this one.
**Describe the solution you would like** > A clear and concise description of what you want to happen. **Supporting documentation** > Please provides links to relevant Kafka protocol docs and/or...
Fixes #1093 Not really familiar with the code base, but I figured out that there are 2 different implementation of the Kafka protocol, so I put the same logic to...
Is there a way to subscribe a topic on demand? I want to subscribe to a new topic without any "regex" correlation with the initial topic. In the case i...
**Describe the solution you would like** Is there a recommended approach to instrumenting the kafka-go library with OpenTelemetry? Standard consumer and producer metrics with support for standard prometheus or otel...
This PR enables `Reader` to notify the user when it reaches the end. This is the same functionality as in librdkafka with config `enable.partition.eof`
