有没有一种方法可以在不从 confluent_kafka 导入 Producer 的情况下实现 Kafka producer?

Is there a way to implement a Kafka producer without importing Producer from confluent_kafka?

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

的模块

kafka-pythonaiokafka 导入生产者然后...?

当然,您可以自己重新实现 TCP 协议,但是如果您使用维护良好的库,您会更快地得到修复,如果有任何其他问题,您将遇到完全相同的问题重大变更

但是,Kafka 协议自 0.10 版以来一直保持向后兼容性(比当前版本早 4 年发布,post!)

我会说你想多了