如何通过Kafka Topic名称查找对应的Source Connector？

当然可以，以下是两种常用的方法，以你提到的etl.userDb.users Topic为例：

方法一：利用Kafka Connect REST API查询 #

Kafka Connect自带REST接口，可直接获取所有Connector的配置信息，通过遍历匹配就能找到目标Topic对应的Connector：

1. 获取所有Connector名称
   发送GET请求到Connect的REST端点，列出所有已部署的Connector：

curl -X GET http://<你的Connect主机>:<端口>/connectors

本地部署场景下，地址通常为http://localhost:8083/connectors。

2. 逐个查询Connector配置
   对返回的每个Connector名称，查询其详细配置：

curl -X GET http://<你的Connect主机>:<端口>/connectors/{connector名称}/config

3. 匹配目标Topic
   在返回的配置中，查找与Topic相关的字段：

• 部分Connector直接用topic字段指定输出Topic；
• Debezium这类CDC连接器，会通过database.server.name（如etl.userDb）结合表名（users）生成etl.userDb.users格式的Topic；
• JDBC Source连接器常用topic.prefix字段，若前缀设为etl.userDb，输出Topic即为etl.userDb.users。
  找到与etl.userDb.users匹配的配置项，对应的就是你要找的Source Connector。

方法二：查看本地Connector配置文件（仅适用于单机部署） #

如果你的Kafka Connect通过本地.properties配置文件启动，直接查看这些文件即可：

• 打开每个Source Connector的配置文件，查找topic、topic.prefix或其他与Topic生成相关的字段；
• 比如Debezium配置中若存在database.server.name=etl.userDb，且同步的是users表，那它就是输出etl.userDb.users Topic的Connector。

注意点 #

• 不同类型的Source Connector，Topic相关的配置字段可能存在差异，需根据Connector类型调整查找方向；
• 分布式模式的Kafka Connect优先使用REST API查询，因为配置存储在Kafka内部Topic中，比本地文件更准确。

内容的提问来源于stack exchange，提问作者Sarath Baiju