from confluent_kafka import Consumer
  

c = Consumer({
    'bootstrap.servers': 'SSL://kafka-main1002.eqiad.wmnet:9093',
    'security.protocol': 'SSL',
    'group.id': 'test-confluent',
    'ssl.endpoint.identification.algorithm': 'HTTPS',  # unset by default disabling hostname verification
    'ssl.ca.location': '/etc/ssl/certs/ca-certificates.crt'  # optional librdkafka seems to load it by default
})
meta = c.list_topics()
print(meta.brokers)