You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ym...@apache.org on 2019/11/05 21:44:49 UTC
[nifi] branch master updated (12bb284 -> 442a80b)
This is an automated email from the ASF dual-hosted git repository.
ymdavis pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 12bb284 NIFI-6841 Fixed checkstyle error introduced in a9db5a8.
add 442a80b NIFI-6819: Add KafkaRecordSink implementations for Kafka 1 and 2 (#3854)
No new revisions were added by this update.
Summary of changes:
.../nifi-kafka-1-0-processors/pom.xml | 12 +-
.../kafka/pubsub/KafkaProcessorUtils.java | 32 +-
.../record/sink/kafka/KafkaRecordSink_1_0.java | 397 +++++++++++++++++++++
.../org.apache.nifi.controller.ControllerService | 2 +-
.../kafka/pubsub/TestConsumeKafkaRecord_1_0.java | 2 +-
.../kafka/pubsub/TestPublishKafkaRecord_1_0.java | 13 +-
.../kafka/pubsub/util/MockRecordWriter.java | 128 -------
.../record/sink/kafka/TestKafkaRecordSink_1_0.java | 211 +++++++++++
.../nifi-kafka-2-0-processors/pom.xml | 11 +
.../kafka/pubsub/KafkaProcessorUtils.java | 22 +-
.../record/sink/kafka/KafkaRecordSink_2_0.java | 397 +++++++++++++++++++++
.../org.apache.nifi.controller.ControllerService | 2 +-
.../kafka/pubsub/TestConsumeKafkaRecord_2_0.java | 2 +-
.../kafka/pubsub/TestPublishKafkaRecord_2_0.java | 2 +-
.../kafka/pubsub/util/MockRecordWriter.java | 128 -------
.../record/sink/kafka/TestKafkaRecordSink_2_0.java | 211 +++++++++++
16 files changed, 1280 insertions(+), 292 deletions(-)
create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/record/sink/kafka/KafkaRecordSink_1_0.java
copy nifi-nar-bundles/{nifi-easyrules-bundle/nifi-easyrules-service => nifi-kafka-bundle/nifi-kafka-1-0-processors}/src/main/resources/META-INF/services/org.apache.nifi.controller.ControllerService (93%)
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/util/MockRecordWriter.java
create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/test/java/org/apache/nifi/record/sink/kafka/TestKafkaRecordSink_1_0.java
create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-0-processors/src/main/java/org/apache/nifi/record/sink/kafka/KafkaRecordSink_2_0.java
copy nifi-nar-bundles/{nifi-easyrules-bundle/nifi-easyrules-service => nifi-kafka-bundle/nifi-kafka-2-0-processors}/src/main/resources/META-INF/services/org.apache.nifi.controller.ControllerService (93%)
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-0-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/util/MockRecordWriter.java
create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-0-processors/src/test/java/org/apache/nifi/record/sink/kafka/TestKafkaRecordSink_2_0.java