kafka-go · Issues· 265 open

Goroutines left behind after writing message even after closing writer

Making the producer backoff algorithm configurable

kafka-go Fetch response negative record count panic

refresh code examples in readme.md

Support for KIP-429: Cooperative rebalancing

ConsumerGroup.joinGroup doesn't handle MemberIdRequired (KIP-394)

Malformed or non-Kafka broker response can cause OOM in protocol.decodeArray

Way to get batch messages and commit if the batch is successful

Make `(msg *Message) totalSize()` public

Endless read from compacted topic/panic or negative count or empty messages

KIP-890: support for transactions v2

messages delivered after WriteMessages returns a context timeout error

Expose error channel to clients when using Writer in async mode

commit offsets manually but in ASYNC

Sticky partitioner/