python kafka出现NoBrokersAvailable错误

除了网上常见的办法，我试了但不好使，于是api_version=(0,10)指定API版本producer = KafkaProducer(key_serializer=lambda k: json.dumps(k).encode('utf-8'),value_serializer=lambda v: json.dumps(v).encode('utf-8'),bootstrap_servers=

spring-java

3705人浏览 · 2021-01-06 10:37:42

spring-java · 2021-01-06 10:37:42 发布

除了网上常见的办法，我试了但不好使，于是api_version=(0,10)指定API版本

producer = KafkaProducer(key_serializer=lambda k: json.dumps(k).encode('utf-8'),value_serializer=lambda v: json.dumps(v).encode('utf-8'),
                        bootstrap_servers=['10.1.6.29:9092'],api_version=(0,10))

华为云开发者联盟

为开发者提供学习成长、分享交流、生态实践、资源工具等服务，帮助开发者快速成长。

更多推荐