Skip to content

Instantly share code, notes, and snippets.

16909055 1.2.2-RC2
%7|1573202362.136|BRKMAIN|confluent.monitoring.interceptor.rdkafka#producer-1| [thrd::0/internal]: :0/internal: Enter main broker thread
%7|1573202362.136|WAKEUPFD|confluent.monitoring.interceptor.rdkafka#producer-1| [thrd:app]: kafka-a.example.com:9092/bootstrap: Enabled low-latency ops queue wake-ups
%7|1573202362.136|BROKER|confluent.monitoring.interceptor.rdkafka#producer-1| [thrd:app]: kafka-a.example.com:9092/bootstrap: Added new broker with NodeId -1
%7|1573202362.136|CONNECT|confluent.monitoring.interceptor.rdkafka#producer-1| [thrd:app]: kafka-a.example.com:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s))
%7|1573202362.136|BRKMAIN|confluent.monitoring.interceptor.rdkafka#producer-1| [thrd:kafka-a.example.com:9092/bootstrap]: kafka-a.example.com:9092/bootstrap: Enter main broker thread
%7|1573202362.136|CONNECT|confluent.monitoring.interceptor.rdkafka#producer-1| [thrd:kafka-a.example.com:9092/bootstrap]: kafka-a.example.c