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/03/02 06:15:03 UTC
[rocketmq-connect] 05/10: Add 'connectors/rocketmq-connect-kafka/' from commit '59ac9fd7b7fd11ad7943b5ef30a3f95b20acadd7'

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 e2861dcabff7a8be4a227e414a6265f289514133
Merge: 8ad0704 59ac9fd
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 14:12:15 2022 +0800

    Add 'connectors/rocketmq-connect-kafka/' from commit '59ac9fd7b7fd11ad7943b5ef30a3f95b20acadd7'
    
    git-subtree-dir: connectors/rocketmq-connect-kafka
    git-subtree-mainline: 8ad07046d7eb4516d8f01dd994de33a18cac3826
    git-subtree-split: 59ac9fd7b7fd11ad7943b5ef30a3f95b20acadd7

 connectors/rocketmq-connect-kafka/README.md        |  30 +++
 connectors/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 connectors/rocketmq-connect-kafka/README.md
index 0000000,213c8fa..213c8fa
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/README.md
+++ b/connectors/rocketmq-connect-kafka/README.md
diff --cc connectors/rocketmq-connect-kafka/pom.xml
index 0000000,ccc4cc1..ccc4cc1
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/pom.xml
+++ b/connectors/rocketmq-connect-kafka/pom.xml
diff --cc connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigDefine.java
index 0000000,9a7f1ba..9a7f1ba
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigDefine.java
+++ b/connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigDefine.java
diff --cc connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigUtil.java
index 0000000,0587dae..0587dae
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigUtil.java
+++ b/connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigUtil.java
diff --cc connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnector.java
index 0000000,680df6e..680df6e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnector.java
+++ b/connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnector.java
diff --cc connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTask.java
index 0000000,f077ac0..f077ac0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTask.java
+++ b/connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTask.java
diff --cc connectors/rocketmq-connect-kafka/src/main/resources/connect-kafka-source.properties
index 0000000,5ab36ed..5ab36ed
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/src/main/resources/connect-kafka-source.properties
+++ b/connectors/rocketmq-connect-kafka/src/main/resources/connect-kafka-source.properties
diff --cc connectors/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnectorTest.java
index 0000000,1e12ca3..1e12ca3
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnectorTest.java
+++ b/connectors/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnectorTest.java
diff --cc connectors/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTaskTest.java
index 0000000,57239f6..57239f6
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTaskTest.java
+++ b/connectors/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTaskTest.java