refs/heads/rocketmq-connect-kafka - rocketmq-externals

commit	59ac9fd7b7fd11ad7943b5ef30a3f95b20acadd7	[log] [tgz]
author	彭小漪 <644120242@qq.com>	Thu Dec 02 16:07:30 2021 +0800
committer	GitHub <noreply@github.com>	Thu Dec 02 16:07:30 2021 +0800
tree	12b9b38638f98d1f5d110b5031dfbb7d7e6902cc
parent	e74c022c593a99b5c79d8e8a774254e7ef44f01a [diff]

tree: 12b9b38638f98d1f5d110b5031dfbb7d7e6902cc

README.md

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”,“tasks.num”:“1”,“kafka.topics”:“test1,test2”,“kafka.group.id”:“group0”,“kafka.bootstrap.server”:“127.0.0.1:9092”,“source-record-converter”:“org.apache.rocketmq.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