Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Sep 17, 2020

• Fix Endless waiting for consumer connection (segmentio#227) (segmentio#430)

  Show description for 7bc2404
  

  dcepelik

  and

  David Čepelík

  authored
  7bc2404

Commits on Sep 17, 2019

• Introduced new pluggable logging API (segmentio#301)

  Show description for 45c0585
  

  mkorolyov

  authored and

  Achille

  committed
  45c0585

Commits on Aug 9, 2019

• Introduced top-level ConsumerGroup construct (segmentio#277)

  Show description for 11670d5
  

  Steve van Loben Sels

  authored
  11670d5

Commits on Jun 21, 2019

• Improved reliability on a couple of flaky tests (segmentio#296)

  

  Steve van Loben Sels

  authored
  8174c4c

Commits on May 7, 2019

• fix record timestamp delta (segmentio#266)

  Show description for c616928
  

  Achille

  authored
  c616928

Commits on Apr 26, 2019

• Don't fail consumer group assignment if topic does not exist (segmentio#262)

  Show description for eda7f37
  

  Steve van Loben Sels

  authored
  eda7f37

Commits on Apr 9, 2019

• Return errors on unknown compression codec (segmentio#255)

  Show description for 20cd820
  stevevls

  authored
  20cd820

Commits on Apr 4, 2019

• Panics have changed with Errors for NewWriter And NewReader (segmentio#246)

  Show description for cd74b6e
  

  olimpias

  authored and

  achille-roussel

  committed
  cd74b6e

Commits on Mar 22, 2019

• reader: allow empty partition assignments when joining a group (segmentio#242)

  

  abuchanan-nr

  authored and

  stevevls

  committed
  50823e6

Commits on Mar 1, 2019

• Use CommitInterval as the commit interval instead of HeartbeatInterval (segmentio#222)

  Show description for 85e5eb4
  

  skoot

  authored and

  stevevls

  committed
  85e5eb4

• Set offset by timestamp. (segmentio#221)

  

  Ray Jenkins

  authored
  b8e28f8

Commits on Feb 21, 2019

• Workaround for racy testReaderStats test (segmentio#214)

  stevevls

  authored
  809ee76

Commits on Feb 14, 2019

• Adding partition watcher, so Kafka-go picks up new partitions. (segmentio#204)

  Show description for 7bb5ea6
  

  ShaneSaww

  authored and

  stevevls

  committed
  7bb5ea6

Commits on Feb 6, 2019

• Downgraded DescribeGroups to v0 for compatibility with 0.10.0 (segmentio#194)

  stevevls

  authored
  6009fd3

• add reader test TestCloseLeavesGroup (segmentio#190)

  

  WillAbides

  authored and

  Steve van Loben Sels

  committed
  abc7b5c

• Ensure reader leaves consumer group on graceful exit (segmentio#189)

  Show description for 62cc6a8
  stevevls

  authored
  62cc6a8

Commits on Nov 25, 2018

• fix kafka.reader.fetch.count metric (segmentio#149)

  Show description for 5a51036
  achille-roussel

  authored
  5a51036

Commits on Nov 15, 2018

• Updated discardN to return errShortRead if N bytes not available (segmentio#143)

  stevevls

  authored
  185fcae

Commits on Oct 25, 2018

• clarify SetOffset usage

  jnjackins

  committed
  f6fb550

• revert changes to consumer group invalid return values

  jnjackins

  committed
  48324a3

Commits on Oct 23, 2018

• Merge remote-tracking branch 'origin/master' into clarify_special_offsets

  jnjackins

  committed
  2602bcb

• fix ConsumerGroup initial offset

  jnjackins

  committed
  3b9595a

Commits on Oct 20, 2018

• Exported Consumer GroupBalancer and made it pluggable (segmentio#124)

  stevevls

  authored
  f64d3ce

Commits on Oct 19, 2018

• Downgrade various api versions to be compatible with kafka 0.10.1 (segmentio#81)

  

  tsholmes

  authored and

  stevevls

  committed
  07715b4

Commits on Jul 12, 2018

• Fix benchmarks

  Pryz

  committed
  7faaf2b

Commits on Feb 22, 2018

• [hot fix] errNotAvailable => errNotAvailableWithGroup

  

  Achille Roussel

  committed
  c4aa0f7

Commits on Jan 11, 2018

• re-enabling detached tests. I may have detached them earlier in testing. (segmentio#61)

  

  savaki

  authored and

  achille-roussel

  committed
  a858dc6

Commits on Jan 10, 2018

• Internally, kafka-go offset is consistent with itself. Unfortunately, not with the rest of the world. The commit offset should be the offset of the next message to read and NOT the last message rea…

  Show description for 9066af4
  

  savaki

  authored and

  achille-roussel

  committed
  9066af4

• add CommitMessages documentation (segmentio#58)

  Show description for 7619f5f
  achille-roussel

  authored
  7619f5f

Commits on Jan 8, 2018

• added consumer group support to Reader (segmentio#55)

  Show description for 949ee27
  

  savaki

  authored and

  achille-roussel

  committed
  949ee27

Commits on Dec 28, 2017

• Reduce test times (segmentio#50)

  Show description for 7e5f87d
  

  savaki

  authored and

  achille-roussel

  committed
  7e5f87d

Commits on Dec 27, 2017

• Add topic partition to message (segmentio#46)

  Show description for f88c22d
  

  savaki

  authored and

  achille-roussel

  committed
  f88c22d

Commits on Oct 31, 2017

• add test

  

  Achille Roussel

  committed
  349a3d2

Commits on Sep 29, 2017

• fix stats

  

  Achille Roussel

  committed
  98dc741

• add reader stats

  

  Achille Roussel

  committed
  15fd5e0

Pagination

PreviousNext