我正在尝试使用来自 Kafka 主题的消息。我正在使用confluent_kafka 消费者的包装器。在开始使用消息之前，我需要检查是否建立了连接。
我读到消费者很懒，所以我需要执行一些操作来建立连接。但我想在不进行consume 或poll 操作的情况下检查连接建立。
另外，我尝试提供一些错误的配置来查看投票的响应。我得到的回应是：
b'Broker: No more messages'
那么，如何判断是连接参数错误、连接断开，还是主题中实际上没有消息？
【问题讨论】：
标签： python apache-kafka kafka-consumer-api kafka-python
恐怕没有直接的方法来测试 Kafka Brokers 是否启动并运行。另请注意，如果您的消费者已经消费了这些消息，这并不意味着这是一种不良行为，显然这并不表示 Kafka 代理已关闭。
一种可能的解决方法是执行某种快速操作并查看代理是否响应。一个例子是列出主题：
使用confluent-kafka-python 和AdminClient
# Example using confuent_kafka
from confluent_kafka.admin import AdminClient
kafka_broker = {'bootstrap.servers': 'localhost:9092'}
admin_client = AdminClient(kafka_broker)
topics = admin_client.list_topics().topics
if not topics:
raise RuntimeError()
# example using kafka-python
import kafka
consumer = kafka.KafkaConsumer(group_id='test', bootstrap_servers=['localhost:9092'])
topics = consumer.topics()
if not topics:
raise RuntimeError()
【讨论】：