Skip to content

Tags: hunkeelin/kafka-go

Tags

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

v0.3.3

Toggle v0.3.3's commit message
ReaderConfig.RetentionTime usage (segmentio#341)

Using RetentionTime from ReaderConfig on create NewConsumerGroup

v0.3.2

Toggle v0.3.2's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
don't use io.StringWriter (segmentio#337)