有没有办法从Kafka的主题名称中找出对应的源连接符？例如：假设我有一个名为“etl.userDb.users”的主题，我想知道哪个源连接器正在向这个主题发布消息。
yduiuuwa1#
如果不将元数据包含在记录本身中或强制+跟踪ACL/证书策略，则不可能找到任何主题生成器。我见过的另一种方法是在所有服务中强制执行集中式日志收集，然后使用主题名称搜索Kafka生产者日志，但这与Kafka工具无关，并且需要较长的数据保留窗口。您可能能够在代理周围/代理上运行tcpdump并检查数据包，但这假定您可以直接访问代理或网络路由器，并且在您收集这些数据包时，生产者实际上是活动的。
bvhaajcl2#
通过对Kafka主题中的信息进行分析，我们可以看到一些与信息产生地有关的信息。
2条答案
按热度按时间yduiuuwa1#
如果不将元数据包含在记录本身中或强制+跟踪ACL/证书策略，则不可能找到任何主题生成器。
我见过的另一种方法是在所有服务中强制执行集中式日志收集，然后使用主题名称搜索Kafka生产者日志，但这与Kafka工具无关，并且需要较长的数据保留窗口。
您可能能够在代理周围/代理上运行tcpdump并检查数据包，但这假定您可以直接访问代理或网络路由器，并且在您收集这些数据包时，生产者实际上是活动的。
bvhaajcl2#
通过对Kafka主题中的信息进行分析，我们可以看到一些与信息产生地有关的信息。