rocketmq-connect-kafka
在启动runtime之后,通过发送http消息到runtime,携带connector和task的参数,启动connector
参数说明
启动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