This is an automated email from the ASF dual-hosted git repository.
wanghailin pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 333dc99cab [Improve][Zeta] Add restore when commit failed (#6101)
add 543d2c5086 [Feature][Connector-v2][PulsarSink]Add Pulsar Sink
Connector. (#4382)
No new revisions were added by this update.
Summary of changes:
.../connector-v2/Error-Quick-Reference-Manual.md | 3 +
docs/en/connector-v2/sink/Pulsar.md | 177 ++++++++++++++
plugin-mapping.properties | 1 +
.../seatunnel/pulsar/config/PulsarConfigUtil.java | 116 ++++++++-
.../seatunnel/pulsar/config/PulsarSemantics.java} | 15 +-
.../seatunnel/pulsar/config/SinkProperties.java | 97 ++++++++
.../pulsar/exception/PulsarConnectorErrorCode.java | 5 +-
.../seatunnel/pulsar/sink/PulsarSink.java | 99 ++++++++
.../seatunnel/pulsar/sink/PulsarSinkCommitter.java | 83 +++++++
.../seatunnel/pulsar/sink/PulsarSinkFactory.java} | 40 ++--
.../seatunnel/pulsar/sink/PulsarSinkWriter.java | 263 +++++++++++++++++++++
.../pulsar/source/reader/PulsarSourceReader.java | 3 +-
.../pulsar/state/PulsarAggregatedCommitInfo.java} | 6 +-
.../seatunnel/pulsar/state/PulsarCommitInfo.java | 11 +-
.../seatunnel/pulsar/state/PulsarSinkState.java | 11 +-
.../e2e/connector/pulsar/PulsarSinkIT.java | 138 +++++++++++
.../src/test/resources/fake_to_pulsar.conf} | 12 +-
.../discovery/AbstractPluginDiscoveryTest.java | 2 +-
.../home/connectors/plugin-mapping.properties | 1 +
19 files changed, 1027 insertions(+), 56 deletions(-)
create mode 100644 docs/en/connector-v2/sink/Pulsar.md
copy
seatunnel-connectors-v2/{connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/config/KafkaSemantics.java
=>
connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/config/PulsarSemantics.java}
(72%)
create mode 100644
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/config/SinkProperties.java
create mode 100644
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/sink/PulsarSink.java
create mode 100644
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/sink/PulsarSinkCommitter.java
copy
seatunnel-connectors-v2/{connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaSinkFactory.java
=>
connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/sink/PulsarSinkFactory.java}
(55%)
create mode 100644
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/sink/PulsarSinkWriter.java
copy
seatunnel-connectors-v2/{connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/state/MongodbCommitInfo.java
=>
connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/state/PulsarAggregatedCommitInfo.java}
(84%)
copy
seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/job/Edge.java
=>
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/state/PulsarCommitInfo.java
(79%)
copy
seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/job/Edge.java
=>
seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/state/PulsarSinkState.java
(79%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-pulsar-e2e/src/test/java/org/apache/seatunnel/e2e/connector/pulsar/PulsarSinkIT.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-kafka-e2e/src/test/resources/kafka_default_sink_fake_to_kafka.conf
=> connector-pulsar-e2e/src/test/resources/fake_to_pulsar.conf} (88%)
