You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by ch...@apache.org on 2022/08/26 09:54:46 UTC
[incubator-eventmesh] 01/01: Merge pull request #1137 from apache/pulsar-connector
This is an automated email from the ASF dual-hosted git repository.
chenguangsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
commit 47db0db4fe5c87c627f1162e3f16c5cd298c165f
Merge: 1ecc60cf def3f1d6
Author: Eason Chen <qq...@gmail.com>
AuthorDate: Fri Aug 26 17:54:39 2022 +0800
Merge pull request #1137 from apache/pulsar-connector
[ISSUE #1040] Apache Pulsar Connector: Producer
.../eventmesh-connector-pulsar/build.gradle | 49 ++++++++++
.../eventmesh-connector-pulsar/gradle.properties | 18 ++++
.../pulsar/common/EventMeshConstants.java | 22 +++++
.../pulsar/config/ClientConfiguration.java | 40 ++++++++
.../pulsar/config/ConfigurationWrapper.java | 72 +++++++++++++++
.../ConnectorResourceServicePulsarImpl.java | 32 +++++++
.../pulsar/producer/AbstractProducer.java | 58 ++++++++++++
.../connector/pulsar/producer/ProducerImpl.java | 102 +++++++++++++++++++++
.../pulsar/producer/PulsarProducerImpl.java | 91 ++++++++++++++++++
.../connector/pulsar/utils/CloudEventUtils.java | 31 +++++++
...ventmesh.api.connector.ConnectorResourceService | 16 ++++
.../org.apache.eventmesh.api.consumer.Consumer | 16 ++++
.../org.apache.eventmesh.api.producer.Producer | 16 ++++
.../src/main/resources/pulsar-client.properties | 18 ++++
.../rocketmq/consumer/PushConsumerImpl.java | 1 -
settings.gradle | 1 +
16 files changed, 582 insertions(+), 1 deletion(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org