kafka-go
kafka-go copied to clipboard
segmentio
Kafka library in Go
**Describe the solution you would like** > A clear and concise description of what you want to happen. **Supporting documentation** > Please provides links to relevant Kafka protocol docs and/or...
**Describe the solution you would like** > A clear and concise description of what you want to happen. **Supporting documentation** > Please provides links to relevant Kafka protocol docs and/or...
It appears that there's demand for bypassing the batching in `Writer.WriteMessages` judging from the comments in https://github.com/segmentio/kafka-go/issues/852#issuecomment-1243061407 I can think of roughly 3 different ways to go about this: 1....
**Describe the bug** So when I use kafka go as a writer, I will randomly get the error `"[3] Unknown Topic Or Partition: the request is for a topic or...
GroupInstanceID can be configured by setting ReaderConfig.GroupInstanceID which will be passed to the joinGroup and heartbeat requests. If the GroupInstanceID has a value the kafka server will set it as...
hi I'm observing a behaviour with few of my topics, where few of my topic consumers are not picking new messages. I debugged around and following is the observation :...
PR makes message `safetyTimeout` configurable because `SetReadDeadline` for msg could differentiate based on the network and make it configurable instead of opinionated configuration
While attempting to switch from an AWS MSK Provisioned Cluster to an MSK Serverless Cluster: Writing messages to topics works, but attempting to read from a topic fails. **Kafka Version**...
**Describe The Bug** ReadPartitions returns an empty list when ACL permissions are missing to list topics (topic read). It takes a long time to figure out the reason for the...
