我目前正在与nodejs和kafka合作,我正在寻找一种方法来检测主题中分区数量的变化(当前使用的是 kafka-node )有什么api可以实现这个功能吗?我想打电话给你 Client.loadMetadataForTopics() 每隔一个小时左右检查分区号,但想知道是否有其他更好的方法可用。任何建议或文件链接也欢迎。非常感谢!
kafka-node
Client.loadMetadataForTopics()
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!