Merge branch 'NIFI-1645' of https://github.com/olegz/nifi into NIFI-1645
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/9e396531 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/9e396531 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/9e396531 Branch: refs/heads/master Commit: 9e39653192161c44b5a591bcfb8517f2df32dc2b Parents: 423b333 e0e00ff Author: Mark Payne <[email protected]> Authored: Wed Mar 23 10:31:57 2016 -0400 Committer: Mark Payne <[email protected]> Committed: Wed Mar 23 10:31:57 2016 -0400 ---------------------------------------------------------------------- .../nifi/processors/kafka/KafkaPublisher.java | 203 ++++ .../nifi/processors/kafka/Partitioners.java | 84 ++ .../apache/nifi/processors/kafka/PutKafka.java | 1050 ++++++------------ .../kafka/SplittableMessageContext.java | 114 ++ .../nifi/processors/kafka/StreamScanner.java | 93 ++ .../processors/kafka/KafkaPublisherTest.java | 205 ++++ .../nifi/processors/kafka/TestPutKafka.java | 545 +++------ .../src/test/resources/log4j.properties | 6 +- 8 files changed, 1155 insertions(+), 1145 deletions(-) ----------------------------------------------------------------------
