-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/69225/
-----------------------------------------------------------
Review request for atlas, Abhishek Kadam, Ashutosh Mestry, keval bhatt,
Kapildeo Nayak, Nixon Rodrigues, and Sarath Subramanian.
Bugs: ATLAS-2947
https://issues.apache.org/jira/browse/ATLAS-2947
Repository: atlas
Description
-------
Introduced following properties to configure name of Kafka topics used by Atlas
server and hooks:
atlas.notification.entities.topic.name=ATLAS_ENTITIES
atlas.notification.hook.topic.name=ATLAS_HOOK
Diffs
-----
distro/src/bin/atlas_config.py f6a6befdd
intg/src/main/java/org/apache/atlas/AtlasConfiguration.java ace8a0fcb
notification/src/main/java/org/apache/atlas/kafka/KafkaNotification.java
624dc5542
notification/src/test/java/org/apache/atlas/hook/AtlasTopicCreatorTest.java
858589817
notification/src/test/java/org/apache/atlas/kafka/KafkaConsumerTest.java
2e8abd759
webapp/src/main/java/org/apache/atlas/notification/NotificationHookConsumer.java
a8f8dd6e7
Diff: https://reviews.apache.org/r/69225/diff/1/
Testing
-------
Verified that Atlas uses the tipic names specified in these properties.
Thanks,
Madhan Neethiraj