Commits

Commits on Feb 26, 2020

Consumer groups use cluster's retention setting by default. (segmentio#406 )
Steve van Loben Sels
authored

Commits on Feb 22, 2020

move writer retries so async messages are retried (segmentio#382 )
abuchanan-nr
authored

Commits on Feb 17, 2020

Added RackAffinityGroupBalancer strategy (segmentio#361 )
Steve van Loben Sels
authored

Commits on Jan 26, 2020

Replace Zstandard wrapper with native Go implementation (segmentio#396 )

pascaldekloe
authored and
Achille
committed

Commits on Jan 7, 2020

add kafka.ApiVersion.Format (segmentio#395 )
Achille
authored
don't export listGroupsResponseV1 (segmentio#394 )
Achille
authored

Commits on Dec 9, 2019

Fix log for syncing assignment (segmentio#385 )

anandsinghkunwar
authored and
Steve van Loben Sels
committed

Commits on Dec 5, 2019

Fix behavior of Conn.ReadPartitions() when no topics specified (segmentio#383 )
Steve van Loben Sels
authored

Commits on Nov 8, 2019

lazily load API versions (segmentio#375 )
Achille
authored

Commits on Nov 1, 2019

Update Error consts and Error.Temporary() (segmentio#372 )

dtjm
authored and
Achille
committed

Commits on Oct 21, 2019

Updated constant for FirstOffset with correct type (segmentio#368 )

anandsinghkunwar
authored and
Achille
committed

Commits on Oct 7, 2019

revisit wire corruption detection (segmentio#324 )
Achille
authored

Commits on Sep 21, 2019

Handle end of fetched batches of messages gracefully (segmentio#353 )
Steve van Loben Sels
authored

Commits on Sep 17, 2019

hot fix: *log.Logger => Logger
Achille Roussel
committed
Introduced new pluggable logging API (segmentio#301 )

mkorolyov
authored and
Achille
committed

Commits on Sep 16, 2019

Log EOF errors to standard logger (segmentio#294 )

dylannz-sailthru
authored and
Achille
committed

Commits on Sep 10, 2019

Extract record batch structure (segmentio#314 )

VictorDenisov
authored and
Achille
committed

Commits on Sep 9, 2019

Optimize message size calculation (segmentio#329 )

sagarkrkv
authored and
Achille
committed
Add max idle conn timeout for Writer. (segmentio#348 )

sagarkrkv
authored and
Achille
committed

Commits on Aug 26, 2019

ReaderConfig.RetentionTime usage (segmentio#341 )

letum
authored and
Steve van Loben Sels
committed

Commits on Aug 22, 2019

segmentio#339 Fix problem with nil keys (segmentio#340 )

Zavierazo
authored and
Achille
committed

Commits on Aug 14, 2019

don't use io.StringWriter (segmentio#337 )
Achille
authored

Commits on Aug 9, 2019

Fixed compatibility with the sarama hash partitioner (segmentio#336 )
Steve van Loben Sels
authored
Fixed a data race in the Hash balancer when using custom hasher (segmentio#335 )
Steve van Loben Sels
authored
Introduced top-level ConsumerGroup construct (segmentio#277 )
Steve van Loben Sels
authored
Add CRC32 and Murmur2 balancers (segmentio#334 )
Steve van Loben Sels
authored
recycle compression buffers (segmentio#320 )
Achille
authored

Commits on Aug 6, 2019

decrease value of seekdontcheck to avoid integer overflow in 386 arch (segmentio#331 )

lovelykd
authored and
Achille
committed

Commits on Jul 30, 2019

Update README.md (segmentio#327 )

ldrrp
authored and
Achille
committed

Commits on Jul 24, 2019

Make sasl.Mechanism safe for concurrent use (segmentio#323 )
Steve van Loben Sels
authored

Commits on Jul 23, 2019

More aggressive resets of state in xerial reader (segmentio#322 )
Steve van Loben Sels
authored

Commits on Jul 22, 2019

Use RequestTimedOut on empty batch instead of errShortRead (segmentio#315 )
Steve van Loben Sels
authored
kafka.writeBuffer (segmentio#318 )
Achille
authored
auto split kafkaURL to array (segmentio#280 )

zgfh
authored and
Achille
committed
Stream compression (segmentio#306 )
Achille
authored