You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2022/09/26 02:13:48 UTC
[incubator-eventmesh] branch master updated (b560c2a3 -> a1211961)
This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from b560c2a3 Merge pull request #1340 from walterlife/workflow-client-java
add 8b8a7f15 Gradle and Module settings
add 8c7229e7 Import Fixes
add 45dd2762 Consumer Initial Implementation
add 55e4f77c Minor Style fix
add 06780bab style fix
add 860e87ca import order fix
add a7c7280f remove invalid code
add ed010fbd License Fix
add 692b1b9d license fix
add 03735d62 Merge branch 'kafka' of https://github.com/Markliniubility/incubator-eventmesh into kafka
add 6cb24fea license fix
add d659e9a9 Update known-dependencies.txt
add 93ca34a8 License Text
add b73fd0af Update Offsets
add c9a79c3e kafka producer
add 4aedef06 Update ProducerImpl.java
add 2055c34e Update PrometheusConfigurationTest.java
add ca613fdc Update PrometheusConfigurationTest.java
add 7368480b config and bug fix
add 6362c915 kafka configs
add e3b1c8ba Merge pull request #1014 from Markliniubility/kafka
add fb5cc6b2 Fix bugs on Producer
add 9e88560d Initial Kafka Consumer Runner Implementation
add fc96d700 consumer runner cont.
add b7673db1 Update build.gradle
add 958ccf83 Merge pull request #1207 from Markliniubility/kafka
add 3be779bb consumer config fix
add 380d1aec manual acknowledge
add d241c584 Merge branch 'kafka' of https://github.com/Markliniubility/incubator-eventmesh into kafka
add 14844f99 style fixing
add 6345542a Update KafkaConsumerRunner.java
add 906a1528 thread safety for set operations
add 003d980a license check fix
add 867afbc0 Update SubscribeProcessor.java
add 2768d047 Merge pull request #1264 from Markliniubility/kafka
add e0cdb2c1 Merge remote-tracking branch 'apache/master' into kafka-connector
new a1211961 Merge pull request #1413 from apache/kafka-connector
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../build.gradle | 22 ++--
.../gradle.properties | 4 +-
.../connector/kafka/common/Constants.java | 12 +-
.../kafka}/common/EventMeshConstants.java | 4 +-
.../kafka}/config/ClientConfiguration.java | 33 +++--
.../kafka}/config/ConfigurationWrapper.java | 7 +-
.../ConnectorResourceServiceKafkaImpl.java} | 6 +-
.../connector/kafka/consumer/ConsumerImpl.java | 135 +++++++++++++++++++++
.../kafka/consumer/KafkaConsumerImpl.java} | 54 +++++----
.../kafka/consumer/KafkaConsumerRunner.java | 118 ++++++++++++++++++
.../kafka/producer/KafkaProducerImpl.java} | 52 ++++----
.../connector/kafka/producer/ProducerImpl.java | 122 +++++++++++++++++++
...ventmesh.api.connector.ConnectorResourceService | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
.../src/main/resources/kafka-client.properties | 135 +++++++++++++++++++++
.../org.apache.io.openmessaging.producer.Producer | 2 +-
.../src/test/resources/kafka-client.properties} | 4 +-
.../rocketmq/consumer/PushConsumerImpl.java | 3 -
.../rocketmq/producer/RocketMQProducerImpl.java | 7 +-
.../config/PrometheusConfigurationTest.java | 2 +-
eventmesh-runtime/build.gradle | 1 +
eventmesh-runtime/conf/eventmesh.properties | 2 +-
.../tcp/client/group/ClientGroupWrapper.java | 3 +-
eventmesh-starter/build.gradle | 1 +
settings.gradle | 1 +
tools/dependency-check/known-dependencies.txt | 5 +
...vents-api.txt => LICENSE-cloudevents-kafka.txt} | 0
...loudevents-api.txt => LICENSE-kafka-client.txt} | 0
...SE-cloudevents-api.txt => LICENSE-lz4-java.txt} | 0
...ENSE-slf4j-api.txt => LICENSE-slf4j-simple.txt} | 0
...cloudevents-api.txt => LICENSE-snappy-java.txt} | 0
.../LINCENSE-zstd-jni.txt} | 23 ++--
33 files changed, 644 insertions(+), 120 deletions(-)
copy eventmesh-connector-plugin/{eventmesh-connector-pulsar => eventmesh-connector-kafka}/build.gradle (77%)
copy eventmesh-connector-plugin/{eventmesh-connector-standalone => eventmesh-connector-kafka}/gradle.properties (95%)
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/ServiceState.java => eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/common/Constants.java (85%)
copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq => eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka}/common/EventMeshConstants.java (87%)
copy eventmesh-connector-plugin/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar => eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka}/config/ClientConfiguration.java (50%)
copy eventmesh-connector-plugin/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar => eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka}/config/ConfigurationWrapper.java (92%)
copy eventmesh-connector-plugin/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/connector/ConnectorResourceServicePulsarImpl.java => eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/connector/ConnectorResourceServiceKafkaImpl.java} (87%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/ConsumerImpl.java
copy eventmesh-connector-plugin/{eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/consumer/StandaloneConsumerAdaptor.java => eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerImpl.java} (69%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerRunner.java
copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/RocketMQProducerImpl.java => eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/KafkaProducerImpl.java} (57%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/ProducerImpl.java
copy eventmesh-connector-plugin/{eventmesh-connector-pravega => eventmesh-connector-kafka}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService (90%)
copy eventmesh-connector-plugin/{eventmesh-connector-redis => eventmesh-connector-kafka}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer (91%)
copy eventmesh-connector-plugin/{eventmesh-connector-redis => eventmesh-connector-kafka}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer (91%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/resources/kafka-client.properties
copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq => eventmesh-connector-kafka}/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer (92%)
copy eventmesh-connector-plugin/{eventmesh-connector-pulsar/src/main/resources/pulsar-client.properties => eventmesh-connector-kafka/src/test/resources/kafka-client.properties} (86%)
copy tools/third-party-licenses/licenses/java/{LICENSE-cloudevents-api.txt => LICENSE-cloudevents-kafka.txt} (100%)
copy tools/third-party-licenses/licenses/java/{LICENSE-cloudevents-api.txt => LICENSE-kafka-client.txt} (100%)
copy tools/third-party-licenses/licenses/java/{LICENSE-cloudevents-api.txt => LICENSE-lz4-java.txt} (100%)
copy tools/third-party-licenses/licenses/java/{LICENSE-slf4j-api.txt => LICENSE-slf4j-simple.txt} (100%)
copy tools/third-party-licenses/licenses/java/{LICENSE-cloudevents-api.txt => LICENSE-snappy-java.txt} (100%)
copy tools/third-party-licenses/licenses/{go/LICENSE-github.com-grpc-ecosystem-grpc-gateway.txt => java/LINCENSE-zstd-jni.txt} (50%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org
[incubator-eventmesh] 01/01: Merge pull request #1413 from apache/kafka-connector
Posted by mi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
commit a1211961b942282912ff9b0719eb454e601d5f17
Merge: b560c2a3 e0cdb2c1
Author: mike_xwm <mi...@126.com>
AuthorDate: Mon Sep 26 10:13:42 2022 +0800
Merge pull request #1413 from apache/kafka-connector
[ISSUE #199] Kafka connector as event storage plugin
close #199
.../eventmesh-connector-kafka/build.gradle | 47 +++++
.../eventmesh-connector-kafka/gradle.properties | 20 ++
.../connector/kafka/common/Constants.java | 9 +-
.../connector/kafka/common/EventMeshConstants.java | 13 +-
.../kafka/config/ClientConfiguration.java | 55 ++++++
.../kafka/config/ConfigurationWrapper.java | 71 +++++++
.../ConnectorResourceServiceKafkaImpl.java | 18 +-
.../connector/kafka/consumer/ConsumerImpl.java | 135 ++++++++++++++
.../kafka/consumer/KafkaConsumerImpl.java | 91 +++++++++
.../kafka/consumer/KafkaConsumerRunner.java | 118 ++++++++++++
.../kafka/producer/KafkaProducerImpl.java} | 52 +++---
.../connector/kafka/producer/ProducerImpl.java | 122 +++++++++++++
...ventmesh.api.connector.ConnectorResourceService | 16 ++
.../org.apache.eventmesh.api.consumer.Consumer | 16 ++
.../org.apache.eventmesh.api.producer.Producer | 16 ++
.../src/main/resources/kafka-client.properties | 135 ++++++++++++++
.../org.apache.io.openmessaging.producer.Producer | 20 ++
.../src/test/resources/kafka-client.properties | 18 ++
.../rocketmq/consumer/PushConsumerImpl.java | 3 -
.../rocketmq/producer/RocketMQProducerImpl.java | 7 +-
.../config/PrometheusConfigurationTest.java | 2 +-
eventmesh-runtime/build.gradle | 1 +
eventmesh-runtime/conf/eventmesh.properties | 2 +-
.../tcp/client/group/ClientGroupWrapper.java | 3 +-
eventmesh-starter/build.gradle | 1 +
settings.gradle | 1 +
tools/dependency-check/known-dependencies.txt | 5 +
.../licenses/java/LICENSE-cloudevents-kafka.txt | 203 +++++++++++++++++++++
.../licenses/java/LICENSE-kafka-client.txt | 203 +++++++++++++++++++++
.../licenses/java/LICENSE-lz4-java.txt | 203 +++++++++++++++++++++
.../licenses/java/LICENSE-slf4j-simple.txt | 21 +++
.../licenses/java/LICENSE-snappy-java.txt | 203 +++++++++++++++++++++
.../licenses/java/LINCENSE-zstd-jni.txt | 26 +++
33 files changed, 1808 insertions(+), 48 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org