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 c92e14168f [Fix][E2E] Fixed e2e test cases of Kafka did not work as
expected (#9359)
add 4cbe3b9172 [improve] rocketmq options (#9251)
No new revisions were added by this update.
Summary of changes:
.../seatunnel/api/ConnectorOptionCheckTest.java | 2 -
.../{Config.java => RocketMqBaseOptions.java} | 26 +-
...roducerConfig.java => RocketMqSinkOptions.java} | 6 +-
...sumerConfig.java => RocketMqSourceOptions.java} | 61 +++--
.../seatunnel/rocketmq/sink/RocketMqSink.java | 149 +++--------
.../rocketmq/sink/RocketMqSinkFactory.java | 26 +-
.../seatunnel/rocketmq/source/RocketMqSource.java | 296 +++++++--------------
.../rocketmq/source/RocketMqSourceFactory.java | 46 ++--
8 files changed, 225 insertions(+), 387 deletions(-)
rename
seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/config/{Config.java
=> RocketMqBaseOptions.java} (89%)
rename
seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/config/{ProducerConfig.java
=> RocketMqSinkOptions.java} (93%)
rename
seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/config/{ConsumerConfig.java
=> RocketMqSourceOptions.java} (90%)
