fix NPE if queueBufferLength is null in KafkaEightSimpleConsumerFireh…

…oseFactory (apache#3345)
harishks · Aug 10, 2016 · b21a98e · b21a98e
1 parent 890e3bd
commit b21a98e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...nsumer/src/main/java/io/druid/firehose/kafka/KafkaEightSimpleConsumerFirehoseFactory.java b/...nsumer/src/main/java/io/druid/firehose/kafka/KafkaEightSimpleConsumerFirehoseFactory.java
@@ -106,7 +106,7 @@ public KafkaEightSimpleConsumerFirehoseFactory(
     );
 
     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);
 
     this.earliest = resetOffsetToEarliest == null ? true : resetOffsetToEarliest.booleanValue();