有没有一种方法来实现Kafka生产者没有从confluent_kafka导入生产者?



我需要在Python中实现Kafka生产者,但我想避免未来可能出现的关于新Kafka版本的问题,所以我想知道是否有可能实现Kafka生产者而不从confluent_kafka导入生产者模块?

kafka-pythonaiokafka进口生产者,然后…?

当然,你可以自己重新实现TCP协议,但是如果你使用一个维护良好的库,你会更快地得到修复,如果有一个突破性的改变,你会在其他任何事情上遇到完全相同的问题

然而,Kafka协议自0.10版本以来一直保持向后兼容性(截至本文发布时,该版本比当前版本早4年发布)

我得说你对这个问题想太多了

最新更新