NIFI-2455 Removing 'Queue Buffering Max Time' as a required property of PutKafka. This closes #765

This commit is contained in:
jpercivall 2016-08-01 20:38:28 -04:00 committed by Matt Gilman
parent ecca76099a
commit 2a6580992b
2 changed files with 1 additions and 3 deletions

View File

@ -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")

View File

@ -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);