Repository: nifi Updated Branches: refs/heads/master ecca76099 -> 2a6580992
NIFI-2455 Removing 'Queue Buffering Max Time' as a required property of PutKafka. This closes #765 Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/2a658099 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/2a658099 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/2a658099 Branch: refs/heads/master Commit: 2a6580992bdbcd4994ddaac29c125a874e39f614 Parents: ecca760 Author: jpercivall <joeperciv...@yahoo.com> Authored: Mon Aug 1 20:38:28 2016 -0400 Committer: Matt Gilman <matt.c.gil...@gmail.com> Committed: Tue Aug 2 17:01:58 2016 -0400 ---------------------------------------------------------------------- .../src/main/java/org/apache/nifi/processors/kafka/PutKafka.java | 2 -- .../test/java/org/apache/nifi/processors/kafka/PutKafkaTest.java | 2 +- 2 files changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/2a658099/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java index 3f6aec4..dc0889a 100644 --- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java +++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java @@ -207,9 +207,7 @@ public class PutKafka extends AbstractKafkaProcessor<KafkaPublisher> { .description("Maximum time to buffer data before sending to Kafka. For example a setting of 100 ms" + " will try to batch together 100 milliseconds' worth of messages to send at once. This will improve" + " throughput but adds message delivery latency due to the buffering.") - .required(true) .addValidator(StandardValidators.TIME_PERIOD_VALIDATOR) - .defaultValue("5 secs") .build(); public static final PropertyDescriptor COMPRESSION_CODEC = new PropertyDescriptor.Builder() .name("Compression Codec") http://git-wip-us.apache.org/repos/asf/nifi/blob/2a658099/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/PutKafkaTest.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/PutKafkaTest.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/PutKafkaTest.java index fbd2963..8437b00 100644 --- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/PutKafkaTest.java +++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/PutKafkaTest.java @@ -89,7 +89,7 @@ public class PutKafkaTest { } @Test - public void validateMultiCharacterDelimiyedMessages() { + public void validateMultiCharacterDelimitedMessages() { String topicName = "validateMultiCharacterDemarcatedMessagesAndCustomPartitioner"; PutKafka putKafka = new PutKafka(); TestRunner runner = TestRunners.newTestRunner(putKafka);
