You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2018/08/06 13:54:52 UTC
[2/2] storm git commit: Merge branch 'custom-kafkabolt-callback' of
https://github.com/dfdemar/storm into STORM-3175-merge
Merge branch 'custom-kafkabolt-callback' of https://github.com/dfdemar/storm into STORM-3175-merge
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/4bc28e7e
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/4bc28e7e
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/4bc28e7e
Branch: refs/heads/master
Commit: 4bc28e7e8ecd13ed7c0a7276927014be1b0dbaff
Parents: 1828a17 d86ef7d
Author: Stig Rohde Døssing <sr...@apache.org>
Authored: Mon Aug 6 15:54:19 2018 +0200
Committer: Stig Rohde Døssing <sr...@apache.org>
Committed: Mon Aug 6 15:54:19 2018 +0200
----------------------------------------------------------------------
.../org/apache/storm/kafka/bolt/KafkaBolt.java | 62 +++++---
.../storm/kafka/bolt/PreparableCallback.java | 32 ++++
.../apache/storm/kafka/bolt/KafkaBoltTest.java | 146 ++++++++++++++-----
3 files changed, 187 insertions(+), 53 deletions(-)
----------------------------------------------------------------------