Skip to content

Tags: dich-dinh-tiki/kafka-go

Tags

v0.2.7

Toggle v0.2.7's commit message

v0.2.6

Toggle v0.2.6's commit message
add auto offset reset

v0.2.5

Toggle v0.2.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.SeekDontCheck (segmentio#295)

* add kafka.SeekDontCheck

* fix logic

* touch less code

* use SeekDontCheck in ReadBatch

* add test

v0.2.4

Toggle v0.2.4's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
fix record timestamp delta (segmentio#266)

* fix record timestamp delta

* better tests

* fix go vet complains

* truncate timestamp to milliseconds in generated message sequences

v0.2.3

Toggle v0.2.3's commit message
Add MaxAttempts to Reader (segmentio#264)

v0.2.2

Toggle v0.2.2's commit message
Small fix to Dialer to set the ServerName in tls.Config if it is empt…

…y. (segmentio#152)

v0.2.1

Toggle v0.2.1's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Updated discardN to return errShortRead if N bytes not available (seg…

…mentio#143)

v0.2.0

Toggle v0.2.0'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#121 from segmentio/clarify_special_offsets

Use named constants for special offsets

v0.1.0

Toggle v0.1.0'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#106 from segmentio/compression-snappy

Add compression