Tags: huangfu/kafka-go
Tags
Fix consumer group timeout handling (segmentio#510) PR segmentio#509 introduced a bug that could create infinite rebalance loops when the Timeout is less than the RebalanceTimeout because the JoinGroup call could timeout before the rebalance completes.
consumer groups: ensure deadline is set on broker interactions (segme… …ntio#509) Since the Conn does not have a timeout by default, it's possible for a connection to hang if the remote side crashes before responding. This PR ensures that every interaction with the broker has a deadline so that the consumer group won't get stuck if the coordinator goes down.
ReadBatchWith bug fix and new MaxWaitTime option (segmentio#482) This fixes a bug where ReadBatchWith could incorrectly return `io.EOF` in certain `errShortRead` scenarios. Since `io.EOF` means the batch was handled correctly, this could cause consumers to continue to use a connection that is in a bad state. This also adds a MaxWait option that can be used to improve the way that the conn deadline and the fetch request interact. Instead of trying to calculate a correct timeout and change the max wait time, this allows the caller to explicitly configure both the wait and the deadline independently of one another.
Merge pull request segmentio#462 from segmentio/fix-retries-3 Revert segmentio#382
add kafka.ApiVersion.Format (segmentio#395) * add kafka.ApiVersion.Format * set explicit constant values intead of using iota
Updated constant for `FirstOffset` with correct type (segmentio#368) Closes segmentio#367
PreviousNext