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>
I tried running the consumer locally (in contrast to the Kubernetes cluster) and see no such logs.
I tried googling for this log message but found no bugs or help avoiding this (though I am not the only person with such logs)
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>
I tried running the consumer locally (in contrast to the Kubernetes cluster) and see no such logs.
I tried googling for this log message but found no bugs or help avoiding this (though I am not the only person with such logs)
- Hi, have you tried to to disable the Telemetry? – Lorenzo Castagno Commented Feb 17 at 15:30
- 1 I can find no mention of "telemetry" in either librd kafka or confluent-kafka-python. Do you have any further input on how to disable this? – Sergej Herbert Commented Feb 17 at 17:40
- Sure, I have added it below. Not sure if that is going to work, but try. – Lorenzo Castagno Commented Feb 17 at 18:38
1 Answer
Reset to default -1As per my previous comment,
from confluent_kafka import Consumer
conf = {
'bootstrap.servers': 'your broker',
'group.id': 'your group',
'auto.offset.reset': 'earliest',
'enable.telemetry': 'false' # Set to False to disable it.
}
consumer = Consumer(conf)