我可以使用docker设置Kafka,但是当我尝试使用python访问它时,我无法做到这一点。如果我在kafka shell中安装python,我可以做到这一点,但在kafka shell之外和dockerpython内部,我无法使用kafka。我的Producer.py文件:import random
#
我使用bitnami/kafkadocker模板创建了一个kafka设置。在多次重新创建容器(我无法连接到9092上的Kafka )之后,我终于启动并运行了我的集群。我认为这些问题是由于Docker安装在Windows上而不是Linux上的事实造成的。我目前的问题是,我无法使用kafka-python库和以下代码来使用任何消息: from kafka import KafkaConsumer
from <
我有一个Spring Boot应用程序,其中有一个Kafka消费者和生产者。还有一个用于创建主题的bean。我的Spring Boot应用程序和Kafka都是在Kubernetes的Docker中启动的。<init>(KafkaConsumer.java:827)
at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer</em