You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@aries.apache.org by cs...@apache.org on 2019/01/11 09:47:00 UTC
[aries-journaled-events] branch master updated (4c15ecf -> 1ad22a3)
This is an automated email from the ASF dual-hosted git repository.
cschneider pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/aries-journaled-events.git.
from 4c15ecf ARIES-1881 Mongo based implementation - Copyright notice updated in test classes.
add 1ad22a3 ARIES-1883 - kafka based implementation
No new revisions were added by this update.
Summary of changes:
org.apache.aries.events.kafka/pom.xml | 47 +++++
.../apache/aries/events/kafka/KafkaEndpoint.java | 31 +++
.../apache/aries/events/kafka/KafkaMessaging.java | 226 +++++++++++++++++++++
.../apache/aries/events/kafka/KafkaPosition.java | 56 +++++
.../aries/events/kafka/KafkaSubscription.java | 85 ++++++++
.../aries/events/kafka/KafkaMessagingTest.java | 81 ++++++++
.../aries/events/kafka/KafkaPositionTest.java | 72 +++++++
.../aries/events/kafka/setup/KafkaBaseTest.java | 122 +++++++++++
.../aries/events/kafka/setup/KafkaLocal.java | 56 +++++
.../aries/events/kafka/setup/ZooKeeperLocal.java | 74 +++++++
pom.xml | 3 +-
11 files changed, 852 insertions(+), 1 deletion(-)
create mode 100644 org.apache.aries.events.kafka/pom.xml
create mode 100644 org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaEndpoint.java
create mode 100644 org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java
create mode 100644 org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaPosition.java
create mode 100644 org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaSubscription.java
create mode 100644 org.apache.aries.events.kafka/src/test/java/org/apache/aries/events/kafka/KafkaMessagingTest.java
create mode 100644 org.apache.aries.events.kafka/src/test/java/org/apache/aries/events/kafka/KafkaPositionTest.java
create mode 100644 org.apache.aries.events.kafka/src/test/java/org/apache/aries/events/kafka/setup/KafkaBaseTest.java
create mode 100644 org.apache.aries.events.kafka/src/test/java/org/apache/aries/events/kafka/setup/KafkaLocal.java
create mode 100644 org.apache.aries.events.kafka/src/test/java/org/apache/aries/events/kafka/setup/ZooKeeperLocal.java