You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gearpump.apache.org by ap...@apache.org on 2016/04/11 20:26:44 UTC
[42/50] incubator-gearpump git commit: Merge pull request #1973 from
manuzhang/kafka_consumer
Merge pull request #1973 from manuzhang/kafka_consumer
fix #1972, backoff retry kafka consuming on exception
Project: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/commit/c7ba3d51
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/tree/c7ba3d51
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/diff/c7ba3d51
Branch: refs/heads/master
Commit: c7ba3d5128ab84d26759fe71b96993d55a870b80
Parents: c3df2ed 9b1085c
Author: Sean Zhong <xi...@intel.com>
Authored: Sat Feb 27 13:54:38 2016 +0800
Committer: Sean Zhong <xi...@intel.com>
Committed: Sat Feb 27 13:54:38 2016 +0800
----------------------------------------------------------------------
.../consumer/ExponentialBackoffSleeper.scala | 58 ++++++++++
.../kafka/lib/consumer/FetchThread.scala | 56 ++++++++--
.../kafka/lib/consumer/KafkaConsumer.scala | 2 +
.../streaming/kafka/lib/FetchThreadSpec.scala | 108 -------------------
.../streaming/kafka/lib/KafkaConsumerSpec.scala | 89 ---------------
.../ExponentialBackoffSleeperSpec.scala | 72 +++++++++++++
.../kafka/lib/consumer/FetchThreadSpec.scala | 108 +++++++++++++++++++
.../kafka/lib/consumer/KafkaConsumerSpec.scala | 88 +++++++++++++++
8 files changed, 373 insertions(+), 208 deletions(-)
----------------------------------------------------------------------