Change Details

from confluent_kafka import Consumer c = Consumer({ 'bootstrap.servers': 'SSL://kafka-main1002.eqiad.wmnet:9093', 'security.protocol': 'SSL', 'group.id': 'test-confluent', 'enable.ssl.certificate.verification': 'true', '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)

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)

from confluent_kafka import Consumer c = Consumer({ 'bootstrap.servers': 'SSL://kafka-main1002.eqiad.wmnet:9093', 'security.protocol': 'SSL', 'group.id': 'test-confluent', 'enable.ssl.certificate.verification': 'true', '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)