[
https://issues.apache.org/jira/browse/ATLAS-3400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sarath Subramanian updated ATLAS-3400:
--------------------------------------
Description:
For clients of AtlasKafkaConsumer (atlas-notification), when kafkaConsumer is
null it results in NPE when trying to poll new messages in receive() method.
{code:java}
java.lang.NullPointerExceptionjava.lang.NullPointerException at
org.apache.atlas.kafka.AtlasKafkaConsumer.receive(AtlasKafkaConsumer.java:69)
{code}
Add null-check on kafkaConsumer object to avoid NPE on client
was:
For clients of AtlasKafkaConsumer (atlas-notification), when kafkaConsumer is
null it results in NPE when trying to poll new messages in receive() method.
{code}
java.lang.NullPointerExceptionjava.lang.NullPointerException at
org.apache.atlas.kafka.AtlasKafkaConsumer.receive(AtlasKafkaConsumer.java:69)
{code}
Add null-check on kafkaConsumer object to avoid NPE on client
> Add null-check on kafkaConsumer object in AtlasKafkaConsumer when polling new
> messages
> --------------------------------------------------------------------------------------
>
> Key: ATLAS-3400
> URL: https://issues.apache.org/jira/browse/ATLAS-3400
> Project: Atlas
> Issue Type: Improvement
> Components: atlas-core
> Affects Versions: 2.0.0
> Reporter: Sarath Subramanian
> Assignee: Sarath Subramanian
> Priority: Major
> Fix For: 2.1.0
>
>
> For clients of AtlasKafkaConsumer (atlas-notification), when kafkaConsumer is
> null it results in NPE when trying to poll new messages in receive() method.
> {code:java}
> java.lang.NullPointerExceptionjava.lang.NullPointerException at
> org.apache.atlas.kafka.AtlasKafkaConsumer.receive(AtlasKafkaConsumer.java:69)
> {code}
>
> Add null-check on kafkaConsumer object to avoid NPE on client
>
>
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
