右配置-

ssl_cafile=/keys/root_ca.pem
    ssl_certfile=/keys/${i}.pem
    ssl_keyfile=/keys/user.key.pem
    ssl_password=<key password>

字符串
您需要将${i}替换为相应的区域名称。例如，如果您连接到美国东部地区，则需要使用以下配置：

ssl_certfile=/keys/us-east.pem

型
ssl_cafile参数指向根CA证书文件。ssl_certfile参数指向要连接到的区域的中间CA证书文件。ssl_keyfile参数指向用户的证书文件。ssl_password参数是用户证书文件的密码。
电子邮件：info@Python Confluent-Kafka SSL Configuration
https://docs.confluent.io/platform/current/kafka/authentication_ssl.html PEM文件使用TLS 1.2。
检查上述过程，我认为它应该是工作

该脚本首先创建/keys/目录，然后导入证书并设置别名。假设服务器配置了SSL，对于us-east，下面是一个python消费者的例子：

from confluent_kafka import Consumer

# Kafka broker URL for us-east region
bootstrap_servers = 'your_us_east_kafka_broker_url:9092'

# Consumer group 
group_id = 'your_consumer_group_id'

 
    # SSL configurations
ssl_ca_location = '/keys/root_ca.pem'
ssl_cert_location = '/keys/us-east.pem'
ssl_key_location = '/keys/us-east.key.pem'  # Replace with the correct key file 
ssl_password = 'your_keystore_password'  # Replace with the correct pwd

    
consumer_config = {
    'bootstrap.servers': bootstrap_servers,
    'group.id': group_id,
    'security.protocol': 'ssl',
    'ssl.ca.location': ssl_ca_location,
    'ssl.certificate.location': ssl_cert_location,
    'ssl.key.location': ssl_key_location,
    'ssl.key.password': ssl_password,
    'auto.offset.reset': 'earliest',  # Adjust as needed
    'enable.auto.commit': False  # Disable auto-commit to have control over committing offsets
}

# Create Kafka consumer
consumer = Consumer(consumer_config)

# Subscribe to topics
topics = ['your_topic']
consumer.subscribe(topics)

# Consume messages
...

字符串