我需要在Python中实现Kafka生产者,但我想避免未来可能出现的关于新Kafka版本的问题,所以我想知道是否有可能实现Kafka生产者而不从confluent_kafka导入生产者模块?
从kafka-python
或aiokafka
进口生产者,然后…?
当然,你可以自己重新实现TCP协议,但是如果你使用一个维护良好的库,你会更快地得到修复,如果有一个突破性的改变,你会在其他任何事情上遇到完全相同的问题
然而,Kafka协议自0.10版本以来一直保持向后兼容性(截至本文发布时,该版本比当前版本早4年发布)
我得说你对这个问题想太多了