Repository Issue Activity (beta)

#1358 Goroutines left behind after writing message even after closing writer

#1285 Making the producer backoff algorithm configurable

#1438 kafka-go Fetch response negative record count panic

#1409 refresh code examples in readme.md

#985 Support for KIP-429: Cooperative rebalancing

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

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

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

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

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

#1428 KIP-890: support for transactions v2

#1427 messages delivered after WriteMessages returns a context timeout error

#1424 kafka-go: `WriterConfig` can’t set `Writer.Completion` (API inconsistency)

#405 Expose error channel to clients when using Writer in async mode

#1423 commit offsets manually but in ASYNC

#1212 getting frequent non-zero number of bytes remaining error during DescribeGroups

#584 Sticky partitioner/

#1291 Kafka Reader unable to read events from kafka when using StartOffset: kafka.LastOffset and GroupID when groupID is new

#852 Create a sane Writer + Batch System

#238 SASL: add support for OAUTHBEARER mechanism

#1414 Reader never recovers when it reads a topic that does not exist yet

#1413 Optional automatic metadata refresh & retry on NotLeaderForPartition

#1393 markRead: negative count still occurs when reading compacted topic from start

#1404 Stats by topic using GroupTopics

#1288 Should retry when the error occurs.kafka.(*Client).Produce: fetch request error: topic partition has no leader