kafka-go
kafka-go copied to clipboard
segmentio
Kafka library in Go
**Describe the bug** We have 30 individual go-routines that we start for individual readers. These read from topics (Not always unique) using unique consumer groupIds. We are seeing scenarios daily...
According to the docs, high-level `Writer` has > Automatic retries and reconnections on errors. But how does it work? Is there any interval between attempts? Any exponential backoff strategy? We...
It seems to me that the current implementation lacks the ability to manually perform read request by a specified offset, like ```golang ctx := context.Background() conn := ... topic :=...
Does this library support any analog of `kafka.ConfigMap` like in https://github.com/confluentinc/confluent-kafka-go?
**Describe the bug** > When producing keyed messages to a specific topic using the writer.WriteMessages(...) method with mutual TLS and ACLs enabled, the client tries to access other topics (for...
We can't see the actual errors of our batch write request. It creates new error and this error does not contain any information about the error return fmt.Sprintf("kafka write errors...
The custom resolver couldn't override the default port even if id had been explicitly provided. The reason for that is unclear as it contradicts the open closed principle. Why: Common...
**Describe the bug** > We can't see the actual errors of our batch write request. It creates new error and this error does not contain any information about the error...
**Describe the bug** When I consumming the messages from a kafka stream, I try to close the reader like this: ``` // reader := kafka.NewReader(*readConfig) reader.Close() ``` I had tried...
Trying to build a administration console for Kafka, so curious if all the admin api are supported?
