与RocketMQ中的mqadmin类似,使用简洁的CLI命令实现增加,删除,查看connector等功能
在rocketmq-connect\rocketmq-connect-CLI目录下,运行sh connectAdmin
The most commonly used connectAdmin commands are:
createConnector Create and start a connector by connector's config
stopConnector Stop a specific connector by connector-name
queryConnectorConfig Get configuration information for a connector
queryConnectorStatus Get Status information for a connector
stopAll Stop and delete all Connectors and all configuration information
reloadPlugins Reload the Connector file under the plugin directory
getConfigInfo Get all configuration information
getClusterInfo Get cluster information
getAllocatedInfo Get the load information of the current worker
See 'connectAdmin help <command>' for more information on a specific command.如上所示,其中列出了最常用的命令,并附有简短说明。要获取每个命令的详细手册,请使用sh connectAdmin help <command>。例如,命令sh connectAdmin help stopConnector将输出如下内容:
$ sh connectAdmin help stopConnector
usage: connectAdmin stopConnector -c <arg> [-h]
-c,--connectorName <arg> connector name
-h,--help Print help提供格式化输出当前connectors和tasks
| taskName | connectorName | status | topic | update-timestamp |
|---|---|---|---|---|
| JdbcSourceTask | jdbcConnectorSource | TERMINATED | jdbcTopic | 1597409102590 |
| FileSourceTask | fileConnectorSource | TERMINATED | fileTopic | 1597409110815 |
| FileSinkTask | fileConnectorSink | STOPPING | fileTopic | 1597409204516 |
其中要说明的一点是,createConnector需要指定配置文件的路径
$ sh connectAdmin help createConnector
usage: connectAdmin createConnector -c <arg> [-h] -p <arg>
-c,--connectorName <arg> connector name
-h,--help Print help
-p,--path <arg> Configuration file pat所以在启动新的connector时,要用-p指定json配置文件的路径,例如
sh connectAdmin createConnector -c fileConnectorSource -p /root/shell/file-connector.json配置文件格式参考具体的connector,这里给出file-connector的格式
{
"connector-class":"org.apache.rocketmq.connect.file.FileSourceConnector",
"topic":"fileTopic",
"filename":"/opt/source-file/source-file.txt",
"source-record-converter":"org.apache.rocketmq.connect.runtime.converter.JsonConverter"
}