Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Aug 20, 2020

• Merge pull request segmentio#491 from segmentio/read-message-documentation

  Show description for ff55ecc
  

  Collin Van Dyck

  authored
  ff55ecc

• Update Reader.ReadMessage offset documentation.

  Show description for 31af6f6
  

  Collin Van Dyck

  committed
  31af6f6

Commits on Aug 13, 2020

• ReadBatchWith bug fix and new MaxWaitTime option (segmentio#482)

  Show description for 0dd85d9
  

  Steve van Loben Sels

  authored
  0dd85d9

Commits on Aug 12, 2020

• make the dial function configurable on the kafka.Dialer type (segmentio#481)

  Show description for b283236
  

  Achille

  and

  pelletier

  authored
  b283236

Commits on Jul 27, 2020

• Update example_consumergroup_test.go (segmentio#472)

  Show description for 16b4e9f
  dmarkhas

  authored
  16b4e9f

Commits on Jun 17, 2020

• Merge pull request segmentio#462 from segmentio/fix-retries-3

  Show description for a92978f
  jnjackins

  authored
  a92978f

Commits on Jun 15, 2020

• Revert "move writer retries so async messages are retried (segmentio#382)"

  Show description for 20f17fc
  jnjackins

  committed
  20f17fc

• fix test

  jnjackins

  committed
  d5019b0

• Merge remote-tracking branch 'origin/master' into fix-retries-2

  jnjackins

  committed
  027dc5f

• Check number of attempts in test

  jnjackins

  committed
  2695e01

Commits on May 14, 2020

• Swap channel pool with sync.Pool + finalizers (segmentio#447)

  Show description for f490bbc
  biasedbit

  authored
  f490bbc

• Fix zstd decoder leak (segmentio#446)

  Show description for 39ad362
  biasedbit

  authored
  39ad362

Commits on May 6, 2020

• Use SwapInt64 to snapshot counters (segmentio#441)

  Show description for 2213fc9
  Nicofuma

  authored
  2213fc9

Commits on Apr 7, 2020

• Ensure Dialer.DialPartition honors configured timeout and deadline (segmentio#425)

  

  Steve van Loben Sels

  authored
  e0af1cf

Commits on Apr 6, 2020

• hot fix: fix unit test failure introduced by segmentio#424

  

  Steve van Loben Sels

  committed
  fae139e

• fix offset commit bug (segmentio#424)

  Show description for c0cc0f5
  

  718529333

  and

  liuzhiqing

  authored
  c0cc0f5

Commits on Mar 11, 2020

• Don't close connection when end of batch is read correctly (segmentio#409)

  Show description for efce7b6
  

  Steve van Loben Sels

  authored
  efce7b6

Commits on Feb 26, 2020

• Consumer groups use cluster's retention setting by default. (segmentio#406)

  Show description for e7c1f56
  

  Steve van Loben Sels

  authored
  e7c1f56

Commits on Feb 22, 2020

• move writer retries so async messages are retried (segmentio#382)

  abuchanan-nr

  authored
  bf3be08

Commits on Feb 17, 2020

• Added RackAffinityGroupBalancer strategy (segmentio#361)

  Show description for 55e867e
  

  Steve van Loben Sels

  authored
  55e867e

Commits on Jan 26, 2020

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

  Show description for 16d85b1
  

  pascaldekloe

  authored and

  Achille

  committed
  16d85b1

Commits on Jan 7, 2020

• add kafka.ApiVersion.Format (segmentio#395)

  Show description for 9a956db
  

  Achille

  authored
  9a956db

• don't export listGroupsResponseV1 (segmentio#394)

  

  Achille

  authored
  a44a65c

Commits on Dec 9, 2019

• Fix log for syncing assignment (segmentio#385)

  Show description for 48f0c13
  

  anandsinghkunwar

  authored and

  Steve van Loben Sels

  committed
  48f0c13

Commits on Dec 5, 2019

• Fix behavior of Conn.ReadPartitions() when no topics specified (segmentio#383)

  Show description for 3b34bbf
  

  Steve van Loben Sels

  authored
  3b34bbf

Commits on Nov 8, 2019

• lazily load API versions (segmentio#375)

  Show description for 3a767ae
  

  Achille

  authored
  3a767ae

Commits on Nov 1, 2019

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

  

  dtjm

  authored and

  Achille

  committed
  ae89ccc

Commits on Oct 21, 2019

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

  Show description for 80057ad
  

  anandsinghkunwar

  authored and

  Achille

  committed
  80057ad

Commits on Oct 7, 2019

• revisit wire corruption detection (segmentio#324)

  Show description for 5e37e04
  

  Achille

  authored
  5e37e04

Commits on Sep 21, 2019

• Handle end of fetched batches of messages gracefully (segmentio#353)

  Show description for 5341c5f
  

  Steve van Loben Sels

  authored
  5341c5f

Commits on Sep 17, 2019

• hot fix: *log.Logger => Logger

  

  Achille Roussel

  committed
  46a3f29

• Introduced new pluggable logging API (segmentio#301)

  Show description for 45c0585
  

  mkorolyov

  authored and

  Achille

  committed
  45c0585

Commits on Sep 16, 2019

• Log EOF errors to standard logger (segmentio#294)

  Show description for 602d499
  

  dylannz-sailthru

  authored and

  Achille

  committed
  602d499

Commits on Sep 10, 2019

• Extract record batch structure (segmentio#314)

  Show description for 0430ada
  

  VictorDenisov

  authored and

  Achille

  committed
  0430ada

Commits on Sep 9, 2019

• Optimize message size calculation (segmentio#329)

  Show description for 752cbf8
  

  sagarkrkv

  authored and

  Achille

  committed
  752cbf8

Pagination

PreviousNext