如何连接到别人的公共Kafka主题

from confluent_kafka import Consumer, KafkaException

# Kafka集群的连接信息
bootstrap_servers = 'broker1:9092,broker2:9092'
group_id = 'my-consumer-group'

# 创建Kafka消费者实例
conf = {
    'bootstrap.servers': bootstrap_servers,
    'group.id': group_id,
    'key.deserializer': 'org.apache.kafka.common.serialization.StringDeserializer',
    'value.deserializer': 'org.apache.kafka.common.serialization.StringDeserializer'
}

if security_enabled:
    conf.update({
        'sasl.mechanism': 'PLAIN',
        'security.protocol': 'SASL_PLAINTEXT',
        'sasl.jaas.config': 'org.apache.kafka.common.security.plain.PlainLoginModule required username="your_username" password="your_password";'
    })

consumer = Consumer(conf)

# 订阅公共主题
topic = 'public_topic'
consumer.subscribe([topic])

try:
    while True:
        msg = consumer.poll(timeout=1.0)
        if msg is None:
            continue
        if msg.error():
            raise KafkaException(msg.error())
        else:
            print(f"Received message: {msg.value().decode('utf-8')}")

except KeyboardInterrupt:
    pass
finally:
    consumer.close()