就最佳性能和更少延迟而言，哪种异步方法更适合解码从Kafka主题消耗的Avro消息？我正在使用Avro库的并发future，并且我仍然可以看到类似的执行时间与不使用并发future的情况相比。fromavro.ioimportBinaryDecoder,DatumReaderfromconfluent_kafka.avro.cached_sc

我正在尝试从kubernetes集群外部连接到kubernetesminikubekafkapod。服务器启动没有任何问题，但我无法设法将本地kafka生产者/消费者连接到外部kafkapod。在集群内的kafka服务器映像上，我将bootstrap-server设置为：bin/kafka-topics.sh--create--bootst