区分librdkafka中不存在和未授权的主题

a0x5cqrl  于 2021-06-05  发布在  Kafka
关注(0)|答案(1)|浏览(388)

如何确定主题是否已授权?
我需要这个,因为在我的消费者中,我得到所有已知主题的元数据,然后分配调用。元数据调用不提供未授权的主题和不存在的主题。如果一个主题不存在,我会创建一个,如果一个主题是未经授权的,我必须失败。但我没有办法区分不存在的主题和未经授权的主题。

sqyvllje

sqyvllje1#

您可以尝试列出所有主题,如果主题存在,它将出现在列表中。我没有使用librdkafka,但仍然从链接中,作者说下面的函数应该给你(没有主题参数)。

rd_kafka_metadata()

相关问题