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 b3cbb0b Add 'connector/rocketmq-connect-jms/' from commit
'37a4db762dfac7496e2e0e40cf7cf25c4bd0f01d'
new d0ff0aa Init rocketmq-kafka connect project
new bbb1202 rocketmq-connect-kafka
new 9aa0640 Update README.md for rocketmq-connect-kafka (#338)
new 598de5d [ISSUE #341] Add wakeup before kafka consumer close to wakeup
consumer poll (#342)
new e74c022 [ISSUE #420]remove openmessage-runtime dependency
new 59ac9fd [rocketmq-connect-kafka]: Completion method
KafkaSourceTask#pause(), KafkaSourceTask#resume(). (#854)
new 00d60fb Add 'connector/rocketmq-connect-kafka/' from commit
'59ac9fd7b7fd11ad7943b5ef30a3f95b20acadd7'
The 7 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
connector/rocketmq-connect-kafka/README.md | 30 +++
.../pom.xml | 77 ++++---
.../connect/kafka/config/ConfigDefine.java | 67 ++++++
.../rocketmq/connect/kafka/config/ConfigUtil.java | 14 +-
.../kafka/connector/KafkaSourceConnector.java | 104 +++++++++
.../connect/kafka/connector/KafkaSourceTask.java | 250 +++++++++++++++++++++
.../main/resources/connect-kafka-source.properties | 12 +-
.../kafka/connector/KafkaSourceConnectorTest.java} | 27 ++-
.../kafka/connector/KafkaSourceTaskTest.java} | 30 +--
9 files changed, 543 insertions(+), 68 deletions(-)
create mode 100644 connector/rocketmq-connect-kafka/README.md
copy connector/{rocketmq-connect-jms => rocketmq-connect-kafka}/pom.xml (82%)
create mode 100644
connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigDefine.java
copy
rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileUtils.java
=>
connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigUtil.java
(90%)
create mode 100644
connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnector.java
create mode 100644
connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTask.java
copy rocketmq-connect-cli/connectAdmin =>
connector/rocketmq-connect-kafka/src/main/resources/connect-kafka-source.properties
(65%)
copy
connector/{rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqConnectorTest.java
=>
rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnectorTest.java}
(69%)
copy
connector/{rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/TimeColumnParser.java
=>
rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTaskTest.java}
(53%)
