我正在使用kafkapython包将消息发布到kafka合流云集群。
我的代码如下所示:
from kafka import KafkaProducer
producer=KafkaProducer(
bootstrap_servers='pkc-epgnk.us-central1.gcp.confluent.cloud:9092',
security_protocol='SASL_SSL',
sasl_mechanism='PLAIN',
ssl_certfile='/usr/local/etc/openssl/cert.pem',
sasl_plain_username='[api_key]',
sasl_plain_password='[api_secret]')
producer.prodcue(topic='file-ingestion',key=b'',value=b'test')
运行上面的代码我得到下面的错误:
kafka.errors.NoBrokersAvailable: NoBrokersAvailable
合流的kafka手册建议我为c/c++生产者设置以下值;但是,我不能由kafka python生产者设置所有值
bootstrap.servers=pkc-epgnk.us-central1.gcp.confluent.cloud:9092
api.version.request=true
broker.version.fallback=0.10.0.0
api.version.fallback.ms=0
sasl.mechanisms=PLAIN
security.protocol=SASL_SSL
ssl.ca.location=/usr/local/etc/openssl/cert.pem
sasl.username=<CLUSTER_API_KEY>
sasl.password=<CLUSTER_API_SECRET>
1条答案
按热度按时间bq3bfh9z1#
您可以使用融合的kafkapython客户机来设置这些属性,并在产品之间获得更好的集成和测试支持
来自github的示例代码