atlas-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ashutosh Mestry <>
Subject Re: Review Request 60816: Addresses Use of KafkaConsumer in Thread by Implementing Kafka's ShutdownableThread
Date Thu, 13 Jul 2017 05:07:31 GMT

This is an automatically generated e-mail. To reply, visit:

(Updated July 13, 2017, 5:07 a.m.)

Review request for atlas, Ayub Pathan, Madhan Neethiraj, and Nixon Rodrigues.


Updates include:
- Added reference section.

Bugs: ATLAS-1944

Repository: atlas

Description (updated)

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.

Kafa provides _ShutdownableThread_ which implements thread-safe way for doing shutdown to
_KafaConsumer_ as used in _AtlasKafkaConsumer_.

- [](
- [Usage sample](


  webapp/src/main/java/org/apache/atlas/notification/ 9e5b864e



**Unit tests**
Executed exisiting tests.

**Functional tests**
- Created entities via Hive.


Ashutosh Mestry

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message