kafka-go
kafka-go copied to clipboard
segmentio
Kafka library in Go
# Description This PR addresses a bug in the Fetch request handling logic. Currently, when an error occurs while reading the header (e.g., OffsetOutOfRange error), the buffer is not returned...
> When we try to produce a message to the kafka topic we receive this error "kafka.(*Client).Produce: [58] SASL Authentication Failed: SASL Authentication failed: [####]: Session too short." Looking at...
**Describe the bug** JoinGroup request sends ProtocolMetadata marked as version v1 https://github.com/segmentio/kafka-go/blob/main/consumergroup.go#L998 but it never provides OwnedPartitions field which is expected by a protocol https://github.com/apache/kafka/blob/trunk/clients/src/main/resources/common/message/ConsumerProtocolSubscription.json#L34 This behavior can affect migration...
**Describe the bug** Hi, we are using kafka-go library in our application and we observed there is a strange rebalance occurs at every 12 hours for the consumer group. Below...
It seems right now there is no support to configure max message size while creating kafka producer. Is it possible to have this support? Other libraries like confluent-kafka-go support this...
**Describe the solution you would like** I am looking to see if it is currently possible to implement this health check idea https://blog.cloudflare.com/intelligent-automatic-restarts-for-unhealthy-kafka-consumers/ with kakfa-go. Some initial struggles I am...
**Describe the solution you would like** I am trying to implement delay queues to create a retry/backoff pattern with Kafka This [blog](https://medium.com/naukri-engineering/retry-mechanism-and-delay-queues-in-apache-kafka-528a6524f722) shows how to do it with Kafka, but...
**Describe the bug** Transport.Resolver docs state: ``` // When set, the Dial function is not responsible for performing name // resolution, and is always called with a pre-resolved address. Resolver...
**Describe the bug** > Many of the reader and consumer group tests sporadically fail. Here are a few recent examples. Some of these are "unsafe" tests, which we only [recently...
