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 <[email protected]> Authored: Sat Feb 27 13:54:38 2016 +0800 Committer: Sean Zhong <[email protected]> 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(-) ----------------------------------------------------------------------
