问题描述
如何确定主题是否经过授权?
How can I make sure if a topic is authorized or not ?
我需要这个，因为在我的消费者中，我获取了所有已知主题的元数据，然后进行了分配呼叫.元数据调用不会提供未授权的主题和不存在的主题.如果一个主题不存在，我将创建一个主题，如果一个主题未经授权，我将失败.但是我没有办法区分不存在和未经授权的话题.
I need this because, in my consumer I get the meta data for all the known topics and then do assign call. The metadata call doesn't give the un-authorized topics and non-existent topic. If a topic doesn't exist, I'll create one and if a topic is unauthorized, I have to fail. But I don't have a way to differentiate between non-existent and unauthorized topic.
推荐答案
您可以尝试列出所有主题，如果该主题存在，则该主题将出现在列表中.我没有使用librdkafka，但仍然使用链接，作者说以下功能应该给你(没有主题参数).
You can try listing all the topics, if the topic exists it will be there in the list. I did not use librdkafka but still from the link, the author says the following function should give you (without the topic argument).
rd_kafka_metadata()
这篇关于区分librdkafka中不存在和未经授权的主题的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！