kafka-go

kafka-go copied to clipboard

petedannemann

## Description Adding kafka-3.x test cases for kafka-go

ssingudasu

Rebalancing the consumer via WatchPartitionChanges doesn't seem to work

3

**Describe the bug** > Rebalancing the consumer via WatchPartitionChanges doesn't seem to work as expected. By increasing the number of partitions the consumers in the group do not rebalancing each...

simone

Duplicate consumption occurs when join a new consumer and CommitInterval is configured

3

In the following code, when a new consumer join the group, duplicate data consumption will be detected. Set CommitInterval to zero can reduce the number of duplicate messages. I suspect...

dalianzhu

Fix FetchMessage return io.EOF error

3

for #1222

zydovech

kafka.Conn.Broker() and kafka.Conn.Controller() return different Host value when there is one broker.

1

**Describe the bug** > A clear and concise description of what the bug is. kafka.Conn.Broker() and kafka.Conn.Controller() return different Host value when there is one broker. **Kafka Version** > *...

longyue0521

I am trying to use the kafka-go package to write data to Kafka asynchronously, but it is not working. When I use synchronous mode, the data is written to Kafka...

HosseinRouhi79

Integration with Opentelemetry standard.

13

I think it would be great if the library supported integration with the Opentelemetry standard. Obvious places for such integration seem to be: - Inserting a traceparent header into the...

maksim77

Reader.Close hangs for ReaderConfig.MaxWait

3

**Describe the bug** After reading once, `Reader.Close` hangs until the end of a `MaxWait` duration. **Kafka Version** 2.3.0 **To Reproduce** ```go package main import ( "context" "fmt" "time" "github.com/segmentio/kafka-go" )...

feldgendler

## Suggestion * I would like to make `totalSize()` public to get to know the exact size of `kakfa.Message` * now the method of knowing the message size is the...

taguhoiya