我想从Kafka主题中消费信息。我正在使用一个包装
我读到消费者是“懒惰”的,所以我需要执行某些操作来建立连接。但我想在不进行
此外,我尝试提供一些错误配置,以查看轮询的响应,但是我得到的响应是:
confluent_kafka
消费者的工具。在开始消费消息之前,我需要检查是否已建立连接。我读到消费者是“懒惰”的,所以我需要执行某些操作来建立连接。但我想在不进行
consume
或poll
操作的情况下检查连接是否已建立。此外,我尝试提供一些错误配置,以查看轮询的响应,但是我得到的响应是:
b'Broker: No more messages'
那么,我该如何确定连接参数是否有误、连接是否断开或者主题中确实没有消息?