This is an automated email from the ASF dual-hosted git repository. zhoubo pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
commit 00d60fb18f82dd396d1ebc0423cde95f32f8fa9e Merge: b3cbb0b 59ac9fd Author: odbozhou <[email protected]> AuthorDate: Wed Mar 2 11:21:08 2022 +0800 Add 'connector/rocketmq-connect-kafka/' from commit '59ac9fd7b7fd11ad7943b5ef30a3f95b20acadd7' git-subtree-dir: connector/rocketmq-connect-kafka git-subtree-mainline: b3cbb0b49f361aeb83fc1ec2d26f00c1d6b6e449 git-subtree-split: 59ac9fd7b7fd11ad7943b5ef30a3f95b20acadd7 connector/rocketmq-connect-kafka/README.md | 30 +++ connector/rocketmq-connect-kafka/pom.xml | 205 +++++++++++++++++ .../connect/kafka/config/ConfigDefine.java | 67 ++++++ .../rocketmq/connect/kafka/config/ConfigUtil.java | 70 ++++++ .../kafka/connector/KafkaSourceConnector.java | 104 +++++++++ .../connect/kafka/connector/KafkaSourceTask.java | 250 +++++++++++++++++++++ .../main/resources/connect-kafka-source.properties | 22 ++ .../kafka/connector/KafkaSourceConnectorTest.java | 57 +++++ .../kafka/connector/KafkaSourceTaskTest.java | 43 ++++ 9 files changed, 848 insertions(+) diff --cc connector/rocketmq-connect-kafka/README.md index 0000000,213c8fa..213c8fa mode 000000,100644..100644 --- a/connector/rocketmq-connect-kafka/README.md +++ b/connector/rocketmq-connect-kafka/README.md diff --cc connector/rocketmq-connect-kafka/pom.xml index 0000000,ccc4cc1..ccc4cc1 mode 000000,100644..100644 --- a/connector/rocketmq-connect-kafka/pom.xml +++ b/connector/rocketmq-connect-kafka/pom.xml diff --cc connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigDefine.java index 0000000,9a7f1ba..9a7f1ba mode 000000,100644..100644 --- a/connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigDefine.java +++ b/connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigDefine.java diff --cc connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigUtil.java index 0000000,0587dae..0587dae mode 000000,100644..100644 --- a/connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigUtil.java +++ b/connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigUtil.java diff --cc connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnector.java index 0000000,680df6e..680df6e mode 000000,100644..100644 --- a/connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnector.java +++ b/connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnector.java diff --cc connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTask.java index 0000000,f077ac0..f077ac0 mode 000000,100644..100644 --- a/connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTask.java +++ b/connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTask.java diff --cc connector/rocketmq-connect-kafka/src/main/resources/connect-kafka-source.properties index 0000000,5ab36ed..5ab36ed mode 000000,100644..100644 --- a/connector/rocketmq-connect-kafka/src/main/resources/connect-kafka-source.properties +++ b/connector/rocketmq-connect-kafka/src/main/resources/connect-kafka-source.properties diff --cc connector/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnectorTest.java index 0000000,1e12ca3..1e12ca3 mode 000000,100644..100644 --- a/connector/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnectorTest.java +++ b/connector/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnectorTest.java diff --cc connector/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTaskTest.java index 0000000,57239f6..57239f6 mode 000000,100644..100644 --- a/connector/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTaskTest.java +++ b/connector/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTaskTest.java
