pythonkubernetesapache-kafkaconfluent-kafka-python

How can I prevent the "Telemetry client instance id changed from AAAAAAAAAAAAAAAAAAAAAA to" log in a confluent-kafka-python consumer?


When the consumer (which is a very simple confluent-kafka-python consumer), we see this log message after the assignment

%6|1739802885.947|GETSUBSCRIPTIONS|<consumer id>#consumer-1| [thrd:main]: Telemetry client instance id changed from AAAAAAAAAAAAAAAAAAAAAA to <some random string>


Solution

  • As per my previous comment,

    from confluent_kafka import Consumer
    
    conf = {
        'bootstrap.servers': 'your broker',
        'group.id': 'your group',
        'enable.metrics.push': False
    }
    
    consumer = Consumer(conf)