在confluent_kafka v0.11.2中正好有一次我怎么办启用.幂等性或者改变加工.保证在python3.6中只需一次就可以实现kafka v0.11.4的融合。来自ConfluentKafka的很多文档只讨论Scala和Java。 我试过这样做: ...2024-07-01 已阅读: n次
“经纪人运输失败”在卡夫卡是什么意思?我正在使用python客户机(confluentkafka)从kafka消费。有时消费者会遇到如下错误: ERROR KafkaError{code=_TRANSPORT,val=-195,str=" ...2024-07-01 已阅读: n次