我们有一个分布式、多区域、多区域的Kafka集群。我们是平台所有者，负责维护和管理集群。有些应用程序利用我们的平台获取其上游/下游数据。现在，我们如何列出正在阅读特定主题的消费者？到目前为止，我了解到，我们可以列出所有的消费者群体，然后对他们进行描述，然后在其中搜索主题。有没有更简单的或其他可用的解决方案？
toiithl61#
如果不通过授权插件进行审计/跟踪，那么描述每个组就是您所能做的最好的了。介绍使用Zipkin进行客户端跟踪的相关博客-https://www.confluent.io/blog/importance-of-distributed-tracing-for-apache-kafka-based-applications/在几份工作中，我看到了几个把关过程，如OpenPolicyAgent、Apache Ranger（用于LDAP集成）、内部Web入职门户等，这些都是访问任何Kafka主题所必需的。
1条答案
按热度按时间toiithl61#
如果不通过授权插件进行审计/跟踪，那么描述每个组就是您所能做的最好的了。
介绍使用Zipkin进行客户端跟踪的相关博客-https://www.confluent.io/blog/importance-of-distributed-tracing-for-apache-kafka-based-applications/
在几份工作中，我看到了几个把关过程，如OpenPolicyAgent、Apache Ranger（用于LDAP集成）、内部Web入职门户等，这些都是访问任何Kafka主题所必需的。