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/sling-org-apache-sling-distribution-journal-kafka.git.
from de8f6e4 Do not send event when interrupted.
add bf09dbc SLING-9504 - Switch from protobuf to json (#7)
No new revisions were added by this update.
Summary of changes:
pom.xml | 7 +-
.../journal/kafka/KafkaClientProvider.java | 56 ++---------
.../journal/kafka/KafkaJsonMessageSender.java | 23 ++++-
.../journal/kafka/KafkaMessageInfo.java | 15 +++
.../journal/kafka/KafkaMessageSender.java | 89 ------------------
.../distribution/journal/kafka/KafkaPoller.java | 11 +--
.../journal/kafka/ProtobufRecordHandler.java | 86 -----------------
.../journal/kafka/JsonMessagingTest.java | 102 ---------------------
.../journal/kafka/KafkaJsonMessageSenderTest.java | 4 +-
.../journal/kafka/KafkaMessageSenderTest.java | 73 ---------------
.../distribution/journal/kafka/MessagingTest.java | 60 ++++++------
.../journal/kafka/ProtobufRecordHandlerTest.java | 53 -----------
.../journal/kafka/util/KafkaLocal.java | 1 +
13 files changed, 78 insertions(+), 502 deletions(-)
delete mode 100644
src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageSender.java
delete mode 100644
src/main/java/org/apache/sling/distribution/journal/kafka/ProtobufRecordHandler.java
delete mode 100644
src/test/java/org/apache/sling/distribution/journal/kafka/JsonMessagingTest.java
delete mode 100644
src/test/java/org/apache/sling/distribution/journal/kafka/KafkaMessageSenderTest.java
delete mode 100644
src/test/java/org/apache/sling/distribution/journal/kafka/ProtobufRecordHandlerTest.java
