目录
由于Kafka Connect的目的是作为一个服务运行,提供了一个用于管理Connector的REST API。默认情况下,此服务的端口是8083。以下是当前支持的终端入口:
(1)获取connect列表:
GET /Connectors:返回活跃的 Connector 列表。
(2)创建新的connect:
POST /Connectors:创建一个新的 Connector;请求的主体是一个包含字符串name字段和对象 config 字段(Connector 的配置参数)的 JSON 对象。
(3)获取指定connect信息:
GET /Connectors/{name}:获取指定 Connector 的信息。
(4)获取指定connect配置参数:
GET /Connectors/{name}/config:获取指定 Connector 的配置参数。
(5)更新指定connect配置参数:
PUT /Connectors/{name}/config:更新指定 Connector 的配置参数。
(6)获取指定connect当前状态:
GET /Connectors/{name}/status:获取 Connector 的当前状态,包括它是否正在运行、失败、暂停等。
(7)获取运行connect任务列表:
GET /Connectors/{name}/tasks:获取当前正在运行的 Connector 的任务列表。
(8)获取指定任务当前状态:
GET /Connectors/{name}/tasks/{taskid}/status:获取任务的当前状态,包括是否是运行中的、失败的、暂停的等。
(9)暂停connect及其任务:
PUT /Connectors/{name}/pause:暂停连接器和它的任务,停止消息处理,直到 Connector 恢复。
(10)恢复暂停的connect:
PUT /Connectors/{name}/resume:恢复暂停的 Connector(如果 Connector 没有暂停,则什么都不做)。
(11)重启故障的connect:
POST /Connectors/{name}/restart:重启 Connector(Connector 已故障)。
(12)重启指定任务:
POST /Connectors/{name}/tasks/{taskId}/restart:重启单个任务 (通常这个任务已失败)。
(13)删除connect及任务配置:
DELETE /Connectors/{name}:删除 Connector, 停止所有的任务并删除其配置。