This is an automated email from the ASF dual-hosted git repository.
wqliang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
from 92eb957cf [ISSUE #4366] When listens for remote nacos offset
configuration, ConnectorRecordPartition deserialization fails. (#4378)
new 9cf176ad1 [ISSUE #4366] When listens for remote nacos offset
configuration, ConnectorRecordPartition deserialization fails.
new 182c50993 [ISSUE #4366] When listens for remote nacos offset
configuration, ConnectorRecordPartition deserialization fails.
new e03d29119 [ISSUE #4366] When listens for remote nacos offset
configuration, ConnectorRecordPartition deserialization fails.
new 08b191554 [ISSUE #4379] Enable manually commit offset in rocketmq
source connector
new 3b7855fde Merge pull request #4380 from xwm1992/fix-4379
The 4414 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:
.../kafka/sink/connector/KafkaSinkConnector.java | 23 +++-
.../source/connector/KafkaSourceConnector.java | 19 +++
.../sink/connector/OpenFunctionSinkConnector.java | 10 ++
.../connector/OpenFunctionSourceConnector.java | 10 ++
.../pulsar/sink/connector/PulsarSinkConnector.java | 15 +++
.../source/connector/PulsarSourceConnector.java | 15 +++
.../redis/sink/connector/RedisSinkConnector.java | 12 ++
.../source/connector/RedisSourceConnector.java | 13 +++
.../sink/connector/RocketMQSinkConnector.java | 12 ++
.../source/connector/RocketMQSourceConnector.java | 129 ++++++++++++++++++++-
.../apache/eventmesh/openconnect/Application.java | 13 +--
.../eventmesh/openconnect/ConnectorWorker.java | 2 +
.../apache/eventmesh/openconnect/SinkWorker.java | 16 ++-
.../apache/eventmesh/openconnect/SourceWorker.java | 50 +++++---
.../openconnect/api/connector/Connector.java | 8 ++
.../api/connector/ConnectorContext.java | 15 +--
...rceConnector.java => SinkConnectorContext.java} | 16 ++-
...eConnector.java => SourceConnectorContext.java} | 18 ++-
18 files changed, 343 insertions(+), 53 deletions(-)
copy
eventmesh-connectors/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/config/KafkaServerConfig.java
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/ConnectorContext.java
(81%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/{SourceConnector.java
=> SinkConnectorContext.java} (75%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/{SourceConnector.java
=> SourceConnectorContext.java} (71%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
