You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@atlas.apache.org by sa...@apache.org on 2019/09/05 05:04:41 UTC
[atlas] branch master updated: ATLAS-3400: Add null-check on
kafkaConsumer object in AtlasKafkaConsumer when polling new messages
This is an automated email from the ASF dual-hosted git repository.
sarath pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/atlas.git
The following commit(s) were added to refs/heads/master by this push:
new 235acae ATLAS-3400: Add null-check on kafkaConsumer object in AtlasKafkaConsumer when polling new messages
235acae is described below
commit 235acae0a040dac438c77e137f6f3e62b2e7e49e
Author: Sarath Subramanian <sa...@apache.org>
AuthorDate: Wed Sep 4 20:36:27 2019 -0700
ATLAS-3400: Add null-check on kafkaConsumer object in AtlasKafkaConsumer when polling new messages
---
.../src/main/java/org/apache/atlas/kafka/AtlasKafkaConsumer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/notification/src/main/java/org/apache/atlas/kafka/AtlasKafkaConsumer.java b/notification/src/main/java/org/apache/atlas/kafka/AtlasKafkaConsumer.java
index 49f9ba3..c38a504 100644
--- a/notification/src/main/java/org/apache/atlas/kafka/AtlasKafkaConsumer.java
+++ b/notification/src/main/java/org/apache/atlas/kafka/AtlasKafkaConsumer.java
@@ -66,7 +66,7 @@ public class AtlasKafkaConsumer<T> extends AbstractNotificationConsumer<T> {
List<AtlasKafkaMessage<T>> messages = new ArrayList();
- ConsumerRecords<?, ?> records = kafkaConsumer.poll(timeoutMilliSeconds);
+ ConsumerRecords<?, ?> records = kafkaConsumer != null ? kafkaConsumer.poll(timeoutMilliSeconds) : null;
if (records != null) {
for (ConsumerRecord<?, ?> record : records) {