《kafka》专题

我们在单独的服务器上运行 zookeeper 3.3 和 kafka 0.8。我们正在使用 HL 消费者，它们按预期访问 kafka 队列中的数据，重新启动时，他们会从上次中断的地方继续。因此，消费者的行为符合预期。问题是当我们使用 zkCli.sh 时，我们无法看到动物园管理员中的偏移量。目前，消费者设置为仅在一个分区中为主题运行。CMD “ls /consumer/mygrpid/offset

我对Couchbase和Kafka很陌生。每当我在Couchbase桶中插入消息时，说“xyz”，连接器就会将其拾取并放入同名的kafka主题中，即“xyz“。到现在为止，一直都还不错。但在这里，我有一个kafka消费者正在运行，它阅读这个主题，并将其放入另一个主题中，比如“abc_123”，但这从未发生过。主要是我在动物园管理员（我作为kafka的一部分运行）中看到了这个错误，并想知道，这是不是

我正在尝试运行一个简单的Spring Boot Kafka应用程序，但我无法使其工作。我遵循了各种教程，现在我正在实现这个教程，但当我启动应用程序时，会发生以下情况： 我可以在控制台中写入，但消费者没有收到任何消息。 这是我的SpringApplication类： application.yml： 消费者类、生产者类及其配置类与教程中所写的相同。< br >在我的server.properties

我所说的集群信息指的是这样的信息 < li >订阅的消费者/消费者群体 < li >读取和提交的偏移量 < li >分区的领导者和追随者 < li >关于服务器等的主题。 zookeeper是将这些信息保存在自己的数据库中（尽管我之前从未听说zookeepher有自己的数据库），还是将这些信息存储在Kafka集群中的一些主题等？ 编辑：以及后续问题：动物园管理员如何从__consumer_offs

我正在学习如何在这个网站链接上使用 Kafka（除了我在 zookeeper 中使用端口 2182），但它显示： 动物园管理员不是公认的选择 执行后： sudo ./bin/kafka-console-consumer.sh --主题测试 --动物园管理员 本地主机：2182 怎么修？ 环境：

我们从kafka向SparkStreaming发送了15张唱片，但是spark只收到了11张唱片。我用的是spark 2.1.0和kafka_2.12-0.10.2.0。 密码 bin/Kafka-console-producer . sh-broker-list localhost:9092-topic input data topic # 1 2 3 4 5 6 7 8 9 10 11 12

我有3个文件- kafka producer.py，consumer.py和spark-job.py。我不知道如何启动spark file来处理来自kafka的生成数据流。 > < li> 在第一个终端中启动zookeeper服务器: 。\ bin \ windows \ zookeeper-start . bat。\config\zookeeper.properties 然后在第二个单独的终端中

我正在尝试从另一个码头工人容器连接到 kafka docker 容器。但它没有连接。 为了运行kafka和zookeeper，我使用了docker compose文件： 容器docker compose 17138956372294708100 _ kafkatest . producer _ 1和docker compose 17138956372294708100 _ kafkatest .

我有 3 个码头工人撰写文件。一个启动Kafka，另外两个是消费者和生产者。在 kafka 中添加了其他 docker 撰写文件中的external_links，但仍然无法从容器内部访问 kafka。从容器外部，我可以通过 localhost：9092 访问，但是在 docker 容器内部呢？

我已经在EC2实例上安装了Apache Kafka，更改了安全组，为Kafka和Zookeeper打开了端口9092和2181。我只有一个代理，一个主题，一个分区，没什么复杂的。我通过尝试当地生产者/消费者来确认Kafka作品。 在AWS安全组上，它显示: 自定义 TCP 规则 TCP 2181 0.0.0.0/0 自定义 TCP 规则 TCP 9092 0.0.0.0/0 现在我想使用我的Bro

我在WSL上运行Kafka。我正试图像这样做一个简单的生产者(我用的是intellj) 但是有一个问题，当我尝试运行代码时，它会显示此错误 我甚至检查了我窗户上的端口 我的问题是，在windows和WSL上运行kafka时，是否不可能制作制片人？

我在Windows 10机器上配置kafka和spring有问题。 我是根据指南做的，我在YouTube找到的https://www.youtube.com/watch?v=IncG0_XSSBg 我在本地怎么都连接不上 spring应用程序非常简单，其任务只是连接到常备服务器。 我已经花了很多时间寻找解决方案，但什么也帮不了我。我尝试了很多。已将其更改为server . properties l

我正在Ubuntu WSL2上成功运行最新的Kafka。我可以在WSL上运行的Ubuntu中启动zookeeper、kafka服务器、创建主题、控制台制作和控制台消费。然而，当我进入Windows上的Intellij并创建一个简单的Java生成器时，它似乎无法连接到代理 版本 服务器属性我在另一个SO答案中找到了此设置，但这些设置对我不起作用。 然后尝试（并重新启动动物园管理员和Kafka） 生产

我在Windows子系统Linux上安装了kafka，并开始使用命令服务启动，所有服务都已启动。现在，当我尝试从Windows运行我的kafka-spring应用程序时，它显示以下错误：- 无法建立与节点-1（localhost/127.0.0.1：9092）的连接。经纪人可能不可用。 我的服务器属性是：- 我哪里出错了？？？

是否有可能将AWS Lambda与Apache Kafka集成在一起？我想在lambda函数中放一个消费者。当使用者收到消息时，lambda函数执行。