Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Feb 15, 2019

• Merge pull request IBM#1160 from thomaslee/tom_backoff_func

  Show description for 6a7bac8
  

  Varun

  authored
  6a7bac8

  Copy full SHA for 6a7bac8

Commits on Jan 25, 2019

• Tests for timestamps added

  

  Sergey Zimin

  committed
  e1eda41

  Copy full SHA for e1eda41

Commits on Aug 30, 2018

• Add Config.Consumer.Retry.BackoffFunc

  

  Tom Lee

  committed
  d6f3bc3

  Copy full SHA for d6f3bc3

Commits on Apr 24, 2018

• Unblock consumer when receiving invalid FetchResponse

  adwinsky

  committed
  d3f8616

  Copy full SHA for d3f8616

Commits on Dec 23, 2017

• advance partition consumer offset after compacted messages

  Show description for d9ef2be
  SamiHiltunen

  committed
  d9ef2be

  Copy full SHA for d9ef2be

Commits on Nov 28, 2017

• Determine the records type based on the magic number not API version

  vlad-arista

  committed
  b7f694e

  Copy full SHA for b7f694e

Commits on Oct 31, 2017

• Add support for Kafka 0.11 in consumer

  Show description for 953231c
  vlad-arista

  committed
  953231c

  Copy full SHA for 953231c

Commits on Aug 22, 2017

• Use a ticker instead of a timer to detect timeouts

  wmille

  committed
  9112d76

  Copy full SHA for 9112d76

• Optionally use a ticker instead of a timer to detect timeouts

  wmille

  committed
  87e4033

  Copy full SHA for 87e4033

Commits on Aug 18, 2017

• Add an optional fast checker to (*partitionConsumer).responseFeeder

  Show description for 7bbb175
  wmille

  committed
  7bbb175

  Copy full SHA for 7bbb175

Commits on Feb 19, 2016

• Makes newMockMetadataResponse exported (fixes IBM#609)

  horkhe

  committed
  5d23f48

  Copy full SHA for 5d23f48

Commits on Feb 3, 2016

• Make mock brokers and protocol packets available for outsider

  horkhe

  committed
  201ab73

  Copy full SHA for 201ab73

Commits on Nov 13, 2015

• Introduce mockSequence and further simplify tests

  horkhe

  committed
  99f4fd7

  Copy full SHA for 99f4fd7

Commits on Oct 28, 2015

• Add an example of using the consumer

  eapache

  committed
  73244fb

  Copy full SHA for 73244fb

Commits on Aug 6, 2015

• Address code inspection comments

  horkhe

  committed
  b26b611

  Copy full SHA for b26b611

Commits on Aug 4, 2015

• Further mock broker improvements

  Show description for b3fa33f
  horkhe

  committed
  b3fa33f

  Copy full SHA for b3fa33f

Commits on Jul 29, 2015

• consumer: don't block on undrained partitions

  Show description for 292f3b0
  eapache

  committed
  292f3b0

  Copy full SHA for 292f3b0

Commits on Jul 22, 2015

• Enhance mock broker

  horkhe

  committed
  da6bc48

  Copy full SHA for da6bc48

Commits on Jun 9, 2015

• Add a missing offset check to a test

  Show description for aff9149
  eapache

  committed
  aff9149

  Copy full SHA for aff9149

Commits on Apr 29, 2015

• Fix/simplify/enable tests

  eapache

  committed
  3bd5a52

  Copy full SHA for 3bd5a52

Commits on Apr 25, 2015

• Add high water mark offset support to the consumer.

  

  Willem van Bergen

  authored and

  wvanbergen

  committed
  5f78d90

  Copy full SHA for 5f78d90

Commits on Apr 16, 2015

• consumer: shut down on OffsetOutOfRange

  Show description for c8b3e2e
  eapache

  committed
  c8b3e2e

  Copy full SHA for c8b3e2e

• Fix TestConsumerBounceWithReferenceOpen

  eapache

  committed
  8372105

  Copy full SHA for 8372105

Commits on Apr 11, 2015

• Consumer: check offset before returning ConsumePartition.

  Show description for d629146
  wvanbergen

  committed
  d629146

  Copy full SHA for d629146

Commits on Mar 20, 2015

• Hopeful quick fix for flaky CI

  eapache

  committed
  3b6fa67

  Copy full SHA for 3b6fa67

Commits on Mar 19, 2015

• consumer: bugfix for broker workers getting stuck

  Show description for d988e6d
  eapache

  committed
  d988e6d

  Copy full SHA for d988e6d

Commits on Mar 16, 2015

• Close the consumer master in tests

  Show description for aef773a
  eapache

  committed
  aef773a

  Copy full SHA for aef773a

Commits on Mar 12, 2015

• Return{Errors,Successes} -> Return.{Errors,Successes}

  wvanbergen

  committed
  4189e55

  Copy full SHA for 4189e55

• Update consumer example comments.

  wvanbergen

  committed
  251a2db

  Copy full SHA for 251a2db

• Rename Ack* configuration names to Return*, make ReturnErrors default to false for the Consumer, update good and examples

  wvanbergen

  committed
  5411ec3

  Copy full SHA for 5411ec3

• Simplify dispatcher loop

  eapache

  committed
  01eada7

  Copy full SHA for 01eada7

Commits on Mar 10, 2015

• Make Consumer and PartitionConsumer interfaces.

  wvanbergen

  committed
  0d6a340

  Copy full SHA for 0d6a340

• Add a test for bug IBM#325

  Show description for ea09ec0
  eapache

  committed
  ea09ec0

  Copy full SHA for ea09ec0

• Clean up and document examples.

  wvanbergen

  committed
  4a62390

  Copy full SHA for 4a62390

Commits on Mar 9, 2015

• Tweaks to consumer_test.rb

  wvanbergen

  committed
  2862e55

  Copy full SHA for 2862e55

Pagination

Previous

Next