Merge branch 'Apache_master_STORM-2407_KafkaTridentMissesData' of https://github.com/hmcl/storm-apache
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/c2c9559f Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/c2c9559f Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/c2c9559f Branch: refs/heads/master Commit: c2c9559f0cac2049a83b026209610bd99dcf6a8e Parents: f5a362a cd3b930 Author: Sriharsha Chintalapani <[email protected]> Authored: Mon Mar 20 10:27:13 2017 -0700 Committer: Sriharsha Chintalapani <[email protected]> Committed: Mon Mar 20 10:27:13 2017 -0700 ---------------------------------------------------------------------- .../trident/OpaqueTridentEventHubEmitter.java | 7 +- .../spout/trident/KafkaTridentSpoutEmitter.java | 94 +++++++------------- .../spout/trident/KafkaTridentSpoutOpaque.java | 8 +- .../kafka/trident/TridentKafkaEmitter.java | 7 +- .../spout/IOpaquePartitionedTridentSpout.java | 29 +++++- .../OpaquePartitionedTridentSpoutExecutor.java | 15 ++-- .../topology/state/TransactionalState.java | 4 + 7 files changed, 74 insertions(+), 90 deletions(-) ----------------------------------------------------------------------
