[ATLAS-3400] Add null-check on kafkaConsumer object in AtlasKafkaConsumer when polling new messages

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.0.0
• Fix Version/s: 2.1.0
• Component/s: atlas-core
• Assignee: Sarath Subramanian
• Reporter: Sarath Subramanian
• Created: 05/Sep/19 03:35
• Updated: 05/Sep/19 05:06
• Resolved: 05/Sep/19 05:06

Description

For clients of AtlasKafkaConsumer (atlas-notification), when kafkaConsumer is null it results in NPE when trying to poll new messages in receive() method.

java.lang.NullPointerExceptionjava.lang.NullPointerException at org.apache.atlas.kafka.AtlasKafkaConsumer.receive(AtlasKafkaConsumer.java:69)

 

Add null-check on kafkaConsumer object to avoid NPE on client