As 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)