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
