使用python-kafka管理客户端,我知道如何创建和删除主题。但是,有没有办法检查这个主题是否存在?如果不是这样的话,我只想创造它。如何在python-kafka管理客户端中实现这一点?我在文件里什么也没看到。
gojuced71#
在不指定可选输入参数的情况下创建kafkaconsumer对象 topics 然后打电话给 .topics() 在创建的对象上。
topics
.topics()
1条答案
按热度按时间gojuced71#
在不指定可选输入参数的情况下创建kafkaconsumer对象
topics
然后打电话给.topics()
在创建的对象上。