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 <[email protected]> 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
