我目前正在尝试从本地计算机访问kafka集群（bitnami），但是问题是，即使在server.properties中公开了所需的主机和端口，并添加了防火墙规则以允许9092端口，它也无法连接。
我正在运行2个代理和1个zookeeper配置。
预期输出：producer.bootstrap\u connected（）应返回true。
实际输出：假
服务器属性

listeners=SASL_PLAINTEXT://:9092
advertised.listeners=SASL_PLAINTEXT://gcp-cluster-name:9092
sasl.mechanism.inter.broker.protocol=PLAIN`
sasl.enabled.mechanisms=PLAIN
security.inter.broker.protocol=SASL_PLAINTEXT

消费者.py

from kafka import KafkaConsumer
import json

sasl_mechanism = 'PLAIN'
security_protocol = 'SASL_PLAINTEXT'

# Create a new context using system defaults, disable all but TLS1.2

context = ssl.create_default_context()
context.options &= ssl.OP_NO_TLSv1
context.options &= ssl.OP_NO_TLSv1_1

consumer = KafkaConsumer('organic-sense',
                         bootstrap_servers='<server-ip>:9092',
                         value_deserializer=lambda x: json.loads(x.decode('utf-8')),
                         ssl_context=context,
                         sasl_plain_username='user',
                         sasl_plain_password='<password>',
                         sasl_mechanism=sasl_mechanism,
                         security_protocol = security_protocol,
                         )

print(consumer.bootstrap_connected())
for data in consumer:
    print(data)