Skip to content

Tags: huangfu/kafka-go

Tags

v0.3.10

Toggle v0.3.10's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
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.

v0.3.9

Toggle v0.3.9's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
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.

v0.3.8

Toggle v0.3.8's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
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.

v0.4.2

Toggle v0.4.2's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
0.4: fix short writes (segmentio#479)

v0.4.1

Toggle v0.4.1's commit message
Merge remote-tracking branch 'origin/0.4' into 0.4-writer

v0.3.7

Toggle v0.3.7's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Merge pull request segmentio#462 from segmentio/fix-retries-3

Revert segmentio#382

v0.4.0

Toggle v0.4.0's commit message
Merge branch '0.4' of ssh://github.com/segmentio/kafka-go into 0.4

v0.3.6

Toggle v0.3.6's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Ensure Dialer.DialPartition honors configured timeout and deadline (s…

…egmentio#425)

v0.3.5

Toggle v0.3.5's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
add kafka.ApiVersion.Format (segmentio#395)

* add kafka.ApiVersion.Format

* set explicit constant values intead of using iota

v0.3.4

Toggle v0.3.4's commit message
Updated constant for `FirstOffset` with correct type (segmentio#368)

Closes segmentio#367