流行的NodeJS Kafka客户端kafkajs在其管理客户端部分有一个方法来列出代理中的所有主题。
https://kafka.js.org/docs/admin
然而,当Kafka用户没有足够的权限来获取这些信息时,这个方法会返回一个空数组,据我所知,这些信息来自某种元数据。
我的问题是,什么是最低数量的特权(读/描述,在什么资源?TOPIC/METADATA)添加到我当前的使用中,以便能够通过kafkajs使用AdminPI.listTopics()?
我只需要所有主题的数组,仅此而已。
1条答案
按热度按时间093gszye1#
阅读主题实体,至少获得列表
Describe用于阅读单个主题配置