kafka-go
kafka-go copied to clipboard
segmentio
Kafka library in Go
There is deployed kafka cluster of 3 nodes. The problem is on the consumer side, if the group coordinator has fallen, then when trying to synchronously commit, it does not...
Suggestion to fix issue https://github.com/segmentio/kafka-go/issues/1314 Steps to reproduce the issue: 1. Create topic 2. Simultaneously connect to this topic with consumer group 3. At some time, if Kafka didn't assigned...
**Describe the solution you would like** Currently, the implementation of `Message` is: ```go type Message struct { // Topic indicates which topic this message was consumed from via Reader. //...
I tried several ways, including setting CommitInterval, to commit automatically, and didn't commit offset through CommitMessages as expected. Here is my sample code. ``` package main import ( "context" "fmt"...
**Describe the solution you would like** > Support for Auth via OIDC token which is being used by Confluent brokers to provide auth for Kakfa services **Supporting documentation** > https://docs.confluent.io/platform/current/security/authentication/sasl/oauthbearer/overview.html
As the title suggests, I found that there are only two authentication methods, namely plain and scram, under the sasl package.
When a reader is used to do an explicit Commit, there wasn't any way to specify the ConsumerGroupConfig.Timeout that was being used for the operation. With this change, we can...
**The kafka configuration has only 60 shards, but the partition that is pushed is not within this access。** **Kafka Version** v0.4.47 **My kafka cluster creation code** ```go func (c cluster)...
**Describe the bug** When I close the reader, it stuck at the `batch.Close()` until it reach `readBatchTimeout` ``` func (r *reader) read(ctx context.Context, offset int64, conn *Conn) (int64, error) {...
**Describe the bug** During routine patching of our MSK Kafka clusters, we see a range of transient errors in our kafka producers (using the kafka-go Writer) as the brokers are...
