-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/59799/
-----------------------------------------------------------
(Updated June 26, 2017, 8:37 a.m.)
Review request for atlas, Apoorv Naik, Ashutosh Mestry, Madhan Neethiraj, and
Sarath Subramanian.
Bugs: ATLAS-1766
https://issues.apache.org/jira/browse/ATLAS-1766
Repository: atlas
Description
-------
This patch include changes that implements kafka new-consumer api for
kafkaConsumer for Atlas Notification System.
Diffs
-----
distro/src/conf/atlas-application.properties 5e59528b
notification/src/main/java/org/apache/atlas/kafka/AtlasKafkaConsumer.java
PRE-CREATION
notification/src/main/java/org/apache/atlas/kafka/AtlasKafkaMessage.java
PRE-CREATION
notification/src/main/java/org/apache/atlas/kafka/KafkaConsumer.java 16c0eb2c
notification/src/main/java/org/apache/atlas/kafka/KafkaNotification.java
8bd31fde
notification/src/main/java/org/apache/atlas/notification/AbstractMessageDeserializer.java
95858278
notification/src/main/java/org/apache/atlas/notification/AbstractNotificationConsumer.java
d4d78de9
notification/src/main/java/org/apache/atlas/notification/NotificationConsumer.java
a99cb105
notification/src/test/java/org/apache/atlas/kafka/KafkaConsumerTest.java
ad7d93e2
notification/src/test/java/org/apache/atlas/kafka/KafkaNotificationMockTest.java
2126be69
notification/src/test/java/org/apache/atlas/kafka/KafkaNotificationTest.java
a8100290
notification/src/test/java/org/apache/atlas/notification/AbstractNotificationConsumerTest.java
13f2f0ba
typesystem/src/test/resources/atlas-application.properties c4ce5eaa
webapp/src/main/java/org/apache/atlas/notification/NotificationHookConsumer.java
2f8245d2
webapp/src/test/java/org/apache/atlas/notification/EntityNotificationIT.java
ac3b5381
webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerKafkaTest.java
18fd2ee2
webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerTest.java
bdb60a2f
webapp/src/test/java/org/apache/atlas/web/integration/BaseResourceIT.java
b59d3ee5
webapp/src/test/java/org/apache/atlas/web/integration/EntityJerseyResourceIT.java
310b2e3e
webapp/src/test/java/org/apache/atlas/web/integration/EntityV2JerseyResourceIT.java
98a7abcf
Diff: https://reviews.apache.org/r/59799/diff/5/
Testing
-------
Tested Kafka consumer on local embeded kafka /zookeeper env.
Tested Atlas Hive hook notifications.
Excecute Quick Start script.
Due to change in kafkaconsumer api the current notification related UT/IT's
need to changed, i have not included this change in this patch but will
included it shortly.
Thanks,
Nixon Rodrigues
