-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/64235/
-----------------------------------------------------------
(Updated Dec. 1, 2017, 5:02 a.m.)
Review request for atlas.
Changes
-------
updated tests for the refactoring of class KafkaNotification
Bugs: ATLAS-2289
https://issues.apache.org/jira/browse/ATLAS-2289
Repository: atlas
Description
-------
- refactored KafkaNotification to isolate the code that deals with embedded
Kafka start/stop to EmbeddedKafkaServer
- added info level logs on critical initialization paths
Diffs (updated)
-----
common/src/main/java/org/apache/atlas/service/Services.java 6f880e4d
notification/src/main/java/org/apache/atlas/kafka/EmbeddedKafkaServer.java
PRE-CREATION
notification/src/main/java/org/apache/atlas/kafka/KafkaNotification.java
152144b3
notification/src/main/java/org/apache/atlas/notification/AbstractNotification.java
8bc7cb4b
notification/src/test/java/org/apache/atlas/kafka/KafkaNotificationTest.java
e0655f3e
webapp/src/test/java/org/apache/atlas/notification/EntityNotificationIT.java
486b30bf
webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerIT.java
f2485939
webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerKafkaTest.java
4ea13c73
webapp/src/test/java/org/apache/atlas/web/integration/BaseResourceIT.java
ab27612e
webapp/src/test/java/org/apache/atlas/web/integration/EntityJerseyResourceIT.java
bae06910
Diff: https://reviews.apache.org/r/64235/diff/2/
Changes: https://reviews.apache.org/r/64235/diff/1-2/
Testing
-------
Verified that Atlas starts up and functions correctly with embedded Kafka.
Thanks,
Madhan Neethiraj