kafka-go
kafka-go copied to clipboard
segmentio
Kafka library in Go
We experience this issue when replaying messages from a compacted topic. For readMessageV2 we actually can receive a batch response with zero header count so this fix will skip the...
It is unclear what is the difference in the behavior when writing with async mode and setting the RequiredAcks to different values: RequireNone, RequireOne, and RequireAll (0, 1, -1). Specifically,...
Hello! I am looking for ways to improve a consumer performance. A found batch reading via DialLeader, but there is no way to specify a consumer group ID, just partition....
When using the GroupID, the SetOffsetAt function does not provide a concise prompt.
Better readability and more intelligent code completion
The MetadataTopics was created to limit unnecessary metadata info but it was never use. Now it should be able to filter metadata based on a given topic
The kafka version is 2.4.1, and we are using compact topic. we have five partition, but now only one partition has data, and when we start to consume data from...
Hi, I am using kafka-go version v0.4.39 How fix error: "Rebalance In Progress: the coordinator has begun rebalancing the group, the client should rejoin the group"? I have ReadMessage in...
I want to use select to read message,like sarama: ` for { select { case message, ok :=
