-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/60816/
-----------------------------------------------------------
Review request for atlas, Ayub Pathan, Madhan Neethiraj, and Nixon Rodrigues.
Bugs: ATLAS-1944
https://issues.apache.org/jira/browse/ATLAS-1944
Repository: atlas
Description
-------
**Background**
Based on discussion with Kafka team member(s), turns out that _KafkaConsumer_
is not thread-safe. This causes probelem during service shutdown as noted in
the ATLAS-1944.
**Solution**
Kafa provides _ShutdownableThread_ which implements thread-safe way for doing
shutdown to _KafaConsumer_ as used in _AtlasKafkaConsumer_.
Diffs
-----
webapp/src/main/java/org/apache/atlas/notification/NotificationHookConsumer.java
9e5b864e
Diff: https://reviews.apache.org/r/60816/diff/1/
Testing
-------
**Unit tests**
Executed exisiting tests.
**Functional tests**
- Created entities via Hive.
Thanks,
Ashutosh Mestry
