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 03:21:39 UTC

[rocketmq-connect] 03/07: Update README.md for rocketmq-connect-kafka (#338)

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 9aa0640e5c84e7c4088a91ce88e349068806b5c2
Author: jonnxu <jo...@163.com>
AuthorDate: Wed Jul 24 09:27:45 2019 +0800

    Update README.md for rocketmq-connect-kafka (#338)
---
 README.md | 29 +++++++++++++++++++++++++++++
 1 file changed, 29 insertions(+)

diff --git a/README.md b/README.md
index 8b13789..d0917cb 100644
--- a/README.md
+++ b/README.md
@@ -1 +1,30 @@
+**rocketmq-connect-kafka**
 
+在启动runtime之后,通过发送http消息到runtime,携带connector和task的参数,启动connector
+
+**参数说明**
+
+- **connector-class**: connector的类名
+- **oms-driver-url**: rocketmq地址
+- **source-record-converter**: source record converter
+- **tasks.num**: 启动的task数目
+- **kafka.topics**: topic列表,多个topic通过逗号“,”隔开
+- **kafka.group.id**: 消费组名,多个connector中,需要保证topic和groupid的一致性
+- **kafka.bootstrap.server**: kafka地址
+
+
+**启动Connector**
+
+http://127.0.0.1:8081/connectors/connector-name?config={"connector-class":"org.apache.rocketmq.connect.kafka.connector.KafkaSourceConnector","oms-driver-url":"oms: rocketmq://127.0.0.1:9876/default:default","tasks.num":"1","kafka.topics":"test1,test2","kafka.group.id":"group0","kafka.bootstrap.server":"127.0.0.1:9092","source-record-converter":"io.openmessaging.connect.runtime.converter.JsonConverter"}
+
+**查看Connector运行状态**
+
+http://127.0.0.1:8081/connectors/connector-name/status
+
+**查看Connector配置**
+
+http://127.0.0.1:8081/connectors/connector-name/config
+
+**关闭Connector**
+
+http://127.0.0.1:8081/connectors/connector-name/stop