Merge branch 'storm826' of https://github.com/zhuoliu/storm into STORM-826
STORM-826: Update KafkaBolt to use the new kafka producer API Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/081af1cf Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/081af1cf Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/081af1cf Branch: refs/heads/master Commit: 081af1cf18b397af5e77c8c83400c8c7dffda1d0 Parents: 577e34e 9319ab1 Author: Robert (Bobby) Evans <[email protected]> Authored: Fri Jun 26 12:58:01 2015 -0500 Committer: Robert (Bobby) Evans <[email protected]> Committed: Fri Jun 26 12:58:01 2015 -0500 ---------------------------------------------------------------------- external/storm-kafka/pom.xml | 10 ++- .../src/jvm/storm/kafka/bolt/KafkaBolt.java | 77 +++++++++++++++++--- .../src/test/storm/kafka/KafkaUtilsTest.java | 32 +++++--- .../test/storm/kafka/bolt/KafkaBoltTest.java | 74 ++++++++++++++++--- 4 files changed, 157 insertions(+), 36 deletions(-) ----------------------------------------------------------------------
