Merge branch '1.x-branch_STORM-2787_KSInitFlag' of https://github.com/hmcl/storm-apache into STORM-2787-on-top-of-STORM-2781-merge-1.x
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/5d0889b8 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/5d0889b8 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/5d0889b8 Branch: refs/heads/1.x-branch Commit: 5d0889b848991613f1c2618afa6330ecbb76a3c9 Parents: 96864e8 7d4ac07 Author: Jungtaek Lim <[email protected]> Authored: Mon Oct 30 09:47:41 2017 +0900 Committer: Jungtaek Lim <[email protected]> Committed: Mon Oct 30 09:47:41 2017 +0900 ---------------------------------------------------------------------- docs/storm-kafka-client.md | 37 +++++-- .../apache/storm/kafka/spout/KafkaSpout.java | 100 +++++++++++-------- .../storm/kafka/spout/KafkaSpoutConfig.java | 55 ++++++---- .../spout/KafkaSpoutMessagingGuaranteeTest.java | 14 +-- 4 files changed, 125 insertions(+), 81 deletions(-) ----------------------------------------------------------------------
