我试图使用 wurstmeister\kafka-docker 镜像和 docker-compose，但是我在连接所有内容方面遇到了真正的问题。 我检查的所有帖子或问题似乎都没有任何问题，但是我真的迷失了方向。（在SO上至少有两个问题试图解决这个问题） 我相信问题出在我对 docker 的...

到目前为止，我还没有看到一个Python客户端明确实现创建主题（topic）的，而不使用配置选项自动创建主题。

Traceback (most recent call last): File "//producer.py", line 1, in <module> from kafka.producer import KafkaProducer File ...

我正在使用Python Kafka高级消费者，想要知道主题每个分区的最新偏移量。但我无法让它工作。from kafka import TopicPartition from kafka.consumer import KafkaConsumer con = KafkaConsumer(boo...

我正在使用通配符模式订阅Kafka，如下所示。通配符代表动态客户ID。consumer.subscribe(pattern='customer.*.validations') 这很有效，因为我可以从主题字符串中提取客户ID。但现在我需要扩展功能，以便监听一个类似的主题，用于稍微不同的目的。让我...

我在Java中使用了Kafka Streams，但在Python中找不到类似的API。 Apache Kafka是否支持Python中的流处理？

我已经开始学习Kafka了，正在尝试进行基本操作。但是我在“Brokers”这个点上遇到了困难。 我的Kafka正在运行，但是当我想创建一个分区时却卡住了。 from kafka import TopicPartition (ERROR THERE) consumer = KafkaCon...

kafka-python (1.0.0) 连接到 broker 时出现错误。同时，/usr/bin/kafka-console-producer 和 /usr/bin/kafka-console-consumer 正常工作。 Python 应用程序之前也能正常工作，但在 zookeeper ...

我使用 KafaConsumer 出现了问题，无法从开头或任何其他显式偏移量读取。 在运行消费者的命令行工具时，如果使用了--from-beginning选项，则会看到相应主题的消息，否则会一直等待。$ ./kafka-console-consumer.sh --zookeeper {loc...

使用 kafka-python 包构建 KafkaProducer 时，我遇到了这个错误：[ERROR] UnrecognizedBrokerVersion: UnrecognizedBrokerVersion Traceback (most recent call last): File...