You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/09/22 05:51:47 UTC
[rocketmq-connect] branch master updated (68e24c49 -> f32d73ea)
This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
from 68e24c49 [ISSUE #286]kafka connector adapter：how map Rocketmq MessageQueue to Kafka TopicPartition (#301)
add f32d73ea [ISSUE #288] redis source connector adapt to new api (#289)
No new revisions were added by this update.
Summary of changes:
connectors/rocketmq-connect-redis/README-CN.md | 14 +++
connectors/rocketmq-connect-redis/README.md | 15 +++
connectors/rocketmq-connect-redis/pom.xml | 2 +-
.../rocketmq/connect/redis/common/Config.java | 22 +----
.../rocketmq/connect/redis/common/Options.java | 32 ++++---
.../connect/redis/common/RedisConstants.java | 1 -
.../redis/connector/RedisSourceConnector.java | 49 +++++-----
.../connect/redis/connector/RedisSourceTask.java | 77 +++++++++-------
.../connect/redis/converter/KVEntryConverter.java | 4 +-
.../redis/converter/RedisEntryConverter.java | 101 +++++++++++----------
.../redis/converter/RedisPositionConverter.java | 6 +-
.../redis/handler/DefaultRedisEventHandler.java | 30 +++---
.../redis/parser/AbstractCommandParser.java | 14 +--
.../connect/redis/parser/CommonParser.java | 12 +--
.../connect/redis/parser/DecrByParser.java | 2 +-
.../redis/parser/DefaultRedisRdbParser.java | 28 +++---
.../rocketmq/connect/redis/parser/DelParser.java | 2 +-
.../rocketmq/connect/redis/pojo/KVEntry.java | 6 --
.../rocketmq/connect/redis/pojo/RedisEntry.java | 14 +--
.../processor/DefaultRedisEventProcessor.java | 40 +++-----
.../redis/processor/RedisClosedListener.java | 6 +-
.../redis/processor/RedisEventListener.java | 24 ++---
.../redis/processor/RedisEventProcessor.java | 6 +-
.../redis/processor/RedisExceptionListener.java | 6 +-
.../connect/redis/util/ParseStringUtils.java | 6 +-
.../rocketmq/redis/test/common/ConfigTest.java | 2 -
.../test/connector/RedisSourceConnectorTest.java | 7 +-
.../redis/test/connector/RedisSourceTaskTest.java | 39 ++------
.../test/connector}/TestPositionStorageReader.java | 2 +-
.../test/connector/TestSourceTaskContext.java | 35 +++----
.../test/converter/RedisEntryConverterTest.java | 20 ++--
.../test/converter/RedisPositionConverterTest.java | 51 -----------
.../rocketmq/redis/test/pojo/KVEntryTest.java | 12 +--
.../redis/test/processor/ListenerTest.java | 6 +-
.../redis/test/processor/ProcessorTest.java | 15 ++-
.../WorkerSinkTaskContextTest.java | 1 +
.../connectorwrapper/WorkerSinkTaskTest.java | 13 ++-
.../distributed/TestConfigManagementService.java | 1 +
38 files changed, 311 insertions(+), 412 deletions(-)
copy {rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl => connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector}/TestPositionStorageReader.java (95%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/TestSourceTaskContext.java (57%)
delete mode 100644 connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisPositionConverterTest.java