kafka-go

kafka-go copied to clipboard

Sending many messages

1

**Describe the bug** When I send a large number of messages via WriteMessages and if at least one of the messages is incorrect, then all subsequent messages in the list...

salakhovilia

Add Conn.WriteMulti function to produce to multiple topics/partitions

2

This function removes the (arbitrary) restriction that a `kafka.Conn` can only write to a single topic+partition. It gives caller a means to publish batches of messages that span topics and...

stevevls

A production-grade sample code on how to read message

3

**Describe the solution you would like** As the developers using this framework, we want a sample code from documentation that is easy to understand and that is production grade The...

silencer07

Implementing Sticky balancer KIP-54

SaiPrasanna9

Consumer group returns empty assignment if one of the topics doesn't exist

2

**Describe the bug** I'm using `ConsumerGroup` API and subscribe to several topics. If one of the topics doesn't exist (but other do), `ConsumerGroup` returns an empty assignment. **Kafka Version** Kafka...

bgranvea

fix partitionWriter has unlimited batch queue size https://github.com/segmentio/kafka-go/issues/819

jseparator

Commit offsets with consumer group?

1

I'm using the consumer group API and this method to commit offsets: ``` // CommitOffsets commits the provided topic+partition+offset combos to the // consumer group coordinator. This can be used...

bgranvea

Update dialer.go

1

"errch

dxasu

Reader block indefinitely during kafka deployment

1

**Describe the bug** If a reader is started before any kafka deployment, whend kafka is finally deployed, the reader block and the ReadMessage function block. **Kafka Version** > * What...

OlivierCazade

when I use SetReadDeadline(time.Time{}), The *Batch loop seems bolcked.

2

when i use example README.md consumer demo, use SetReadDeadline(time.Time{}), can't print read message Kafka Version use this image wurstmeister/kafka:2.12-2.1.1 What version(s) of Kafka are you testing against? default config set...

Mrmanbanpai