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:05:43 UTC
[atlas] branch branch-2.0 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 branch-2.0
in repository https://gitbox.apache.org/repos/asf/atlas.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new f3026c2 ATLAS-3400: Add null-check on kafkaConsumer object in AtlasKafkaConsumer when polling new messages
f3026c2 is described below
commit f3026c2cda689859a9982218e05b3f50ceb6c5c0
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
(cherry picked from commit 235acae0a040dac438c77e137f6f3e62b2e7e49e)
---
.../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) {