kafka-go
kafka-go copied to clipboard
segmentio
Kafka library in Go
**ConsumerRebalance Listener methods implementations in kafka-go** Is there a way for me to flush and commit offsets on partitions revoked? Additional questions (sorry I'm really new to this lib): 1....
**Describe the bug** The library picks up that the amount of partitions on a topic have changed (via the PartitionWatcher) but the subsequent stop/join flow doesn't generate a new generation...
Greetings! I want to implement sticky partitioner for my application by implementing Balancer and almost everything seems to be just fine except one small thingy - it is impossible to...
**Describe the bug** When subscribing to a compacted topic that contains tombstone messages, these messages are not received with null as the payload but instead the subject is always 4...
In my case, I have serveral workers to consume kafka message. My program will create serveral mem queues to handle the message sequentially by `Message.Key`, and handle the commit of...
**Describe the bug** We have an application using the v0.4.12 and `kafka.NewWriter`. It's a small pinger application that instantiates a new `kafka.NewWriter` every second, sends a message a receives it....
**Describe the bug** Upgrading _kafka-go_ client with no client code changes from v0.3.5 to v0.4.10, when the first (kafka-go) `writer.WriteMessages()` call is made, the client returns error message: **"context deadline...
**Describe the bug** `conn.ReadMessage` return EOF error after 10 mins no messages to consumer **Kafka Version** KAFKA_VERSION: 2.7.0 kafka-go version: v0.4.15 **To Reproduce** ```go package main import ( "context" "fmt"...
**Describe the solution you'd like** We are depending on an outdated version of the lz4 package, we should upgrade to the latest which currently is v4. https://github.com/pierrec/lz4/tree/v4
**Describe the solution you'd like** The use of `errShortRead` in the kafka-go code should be wrapped with `fmt.Errorf` to provide contextual information about why we hit that error. We would...