我正在使用confluent-kafka-go库的通道生产者示例编写Go语言生成器。当我使用正常运行的代理运行我的应用程序时,通过从
如何从库中接收这些事件?澄清一下,我对像RD_KAFKA_RESP_ERR__FAIL这样在docs中描述的错误感兴趣。
range producer.Events()
读取已生成事件。
但是当代理服务器宕机时,我会在stderr中获取如下来自kafka库的日志,但是我无法找到一种方法让我的应用程序注册这些错误以便我可以检测到它们:
%3|1528267290.204|FAIL|rdkafka#producer-1| [thrd:xxx.xxx.com:9092/bootstrap]: xxx.xxx.com:9092/bootstrap: Connect to ipv4#xxx.xxx.xxx.xxx:9092 failed: Connection refused
%3|1528267290.204|ERROR|rdkafka#producer-1| [thrd:xxx.xxx.com:9092/bootstrap]: 1/1 brokers are down
如何从库中接收这些事件?澄清一下,我对像RD_KAFKA_RESP_ERR__FAIL这样在docs中描述的错误感兴趣。