Как получить события для ошибок брокера kafka, используя confluent-kafka-go - PullRequest
Новая
       17

Как получить события для ошибок брокера kafka, используя confluent-kafka-go

0 голосов
/ 06 июня 2018

Я пишу продюсер на go, используя пример продюсера канала библиотеки confluent-kafka-go.Когда я запускаю свое приложение с работающими брокерами, я получаю созданные события, читая из range producer.Events().

Но когда брокеры не работают, я получаю журналы, подобные следующим, из библиотеки kafka, напечатанной в stderr, но яя не могу найти способ для моего приложения регистрировать эти ошибки, чтобы я мог их обнаружить: 

%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, описанные в документах

1 Ответ

0 голосов
/ 28 августа 2018

Кажется, что не было никакого способа получить ошибки, я открыл проблему, и исправление будет скоро выпущено в v0.11.5:

https://github.com/confluentinc/confluent-kafka-go/issues/200

...