0e7f8ea4603c858cc295259bbd1a22314b732f62 - incubator-atlas

commit	0e7f8ea4603c858cc295259bbd1a22314b732f62	[log] [tgz]
author	nixonrodrigues <nixon@apache.org>	Mon Jun 05 12:49:27 2017 +0530
committer	Madhan Neethiraj <madhan@apache.org>	Mon Jun 26 08:07:12 2017 -0700
tree	2a9da0bd164b15a6e98b2f03d6a8a5e5fca121f0
parent	5bb2dcbeb366a2e09423811506078b8e5ddf19f3 [diff]

ATLAS-1766: updated NotificationConsumer implementation to use new Kafka Consumer API, to enable support for SASL_SSL protocol

Signed-off-by: Madhan Neethiraj <madhan@apache.org>

distro/src/conf/atlas-application.properties[diff]
notification/src/main/java/org/apache/atlas/kafka/AtlasKafkaConsumer.java[Added - diff]
notification/src/main/java/org/apache/atlas/kafka/AtlasKafkaMessage.java[Added - diff]
notification/src/main/java/org/apache/atlas/kafka/KafkaConsumer.java[Deleted - diff]
notification/src/main/java/org/apache/atlas/kafka/KafkaNotification.java[diff]
notification/src/main/java/org/apache/atlas/notification/AbstractMessageDeserializer.java[diff]
notification/src/main/java/org/apache/atlas/notification/AbstractNotificationConsumer.java[diff]
notification/src/main/java/org/apache/atlas/notification/NotificationConsumer.java[diff]
notification/src/test/java/org/apache/atlas/kafka/KafkaConsumerTest.java[diff]
notification/src/test/java/org/apache/atlas/kafka/KafkaNotificationMockTest.java[diff]
notification/src/test/java/org/apache/atlas/kafka/KafkaNotificationTest.java[diff]
notification/src/test/java/org/apache/atlas/notification/AbstractNotificationConsumerTest.java[diff]
typesystem/src/test/resources/atlas-application.properties[diff]
webapp/src/main/java/org/apache/atlas/notification/NotificationHookConsumer.java[diff]
webapp/src/test/java/org/apache/atlas/notification/EntityNotificationIT.java[diff]
webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerKafkaTest.java[diff]
webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerTest.java[diff]
webapp/src/test/java/org/apache/atlas/web/integration/BaseResourceIT.java[diff]
webapp/src/test/java/org/apache/atlas/web/integration/EntityJerseyResourceIT.java[diff]
webapp/src/test/java/org/apache/atlas/web/integration/EntityV2JerseyResourceIT.java[diff]

20 files changed

tree: 2a9da0bd164b15a6e98b2f03d6a8a5e5fca121f0