Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix NPE if queueBufferLength is null in KafkaEightSimpleConsumerFirehoseFactory (#3345)

This commit is contained in:
kaijianding 2016-08-10 22:59:17 +08:00 committed by Charles Allen
parent 890e3bdd3f
commit b21a98e2f6
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
extensions-contrib/kafka-eight-simpleConsumer/src/main/java/io/druid/firehose/kafka/KafkaEightSimpleConsumerFirehoseFactory.java
View File

@ -106,7 +106,7 @@ public class KafkaEightSimpleConsumerFirehoseFactory implements
); );
this.queueBufferLength = queueBufferLength == null ? DEFAULT_QUEUE_BUFFER_LENGTH : queueBufferLength; this.queueBufferLength = queueBufferLength == null ? DEFAULT_QUEUE_BUFFER_LENGTH : queueBufferLength;
Preconditions.checkArgument(queueBufferLength > 0, "queueBufferLength must be positive number"); Preconditions.checkArgument(this.queueBufferLength > 0, "queueBufferLength must be positive number");
log.info("queueBufferLength loaded as[%s]", this.queueBufferLength); log.info("queueBufferLength loaded as[%s]", this.queueBufferLength);
this.earliest = resetOffsetToEarliest == null ? true : resetOffsetToEarliest.booleanValue(); this.earliest = resetOffsetToEarliest == null ? true : resetOffsetToEarliest.booleanValue();