如何确定主题是否已授权?我需要这个,因为在我的消费者中,我得到所有已知主题的元数据,然后分配调用。元数据调用不提供未授权的主题和不存在的主题。如果一个主题不存在,我会创建一个,如果一个主题是未经授权的,我必须失败。但我没有办法区分不存在的主题和未经授权的主题。
sqyvllje1#
您可以尝试列出所有主题,如果主题存在,它将出现在列表中。我没有使用librdkafka,但仍然从链接中,作者说下面的函数应该给你(没有主题参数)。
rd_kafka_metadata()
1条答案
按热度按时间sqyvllje1#
您可以尝试列出所有主题,如果主题存在,它将出现在列表中。我没有使用librdkafka,但仍然从链接中,作者说下面的函数应该给你(没有主题参数)。