当前位置: 首页 > 知识库问答 >
问题:

kafka多节点设置活动-活动

邓子濯
2023-03-14

我是Kafka的初来乍到,有一些基本的怀疑。我试着做一个Kafka建立的多节点(主动-主动)。情况如下:-

  1. 运行单个zookeeper(端口:2181)
  2. 创办了三家Kafka经纪人(9092、9093、9094)
  3. 创建单个主题测试(分区:1,复制3)
  4. 使用代理列表启动生产者(9092,9093)
  5. 在9092、9093、9094上启动了使用者,但它们都在使用相同的主题。

现在我怀疑的是,当我从生产者发送一个消息时,它被三个消费者都消费了,

这是否意味着它在复制信息?

Q2.由于生产者正在9092、9093上运行,那么为什么9094端口上的消费者正在使用消息?是因为它使用了相同的主题名称吗?

感谢任何帮助。

共有1个答案

楚德辉
2023-03-14

我已经在评论中回答了,但这确实是一个问题,归结为缺乏对Kafaka消费群体的了解。用这种格式讨论太长了,所以我将在这里指导您https://kafka.apache.org/documentation/#TheConsumer

 类似资料:
  • 专题活动 设置专题相关活动 如同某宝双11,双12,某东年货节的专场页面,我们推出了专场页面,页面可以由平台方、站点、商家进行创建使用,页面也由各方自行编辑。 打开后台-营销-营销中心-店铺营销-专题活动 一、专题活动列表 进行中:预览、编辑、详情、关闭 已关闭: 已结束:预览、编辑、详情、删除 二、专题活动添加 活动信息 专题名称、关键字、描述、背景色、有效时间 图像:专题活动列表中单独专题背景

  • 根据如何在Ubuntu中安装Apache Hadoop2.6.0(多节点/集群设置),我将Hadoop2.6.0设置为1个主服务器和2个从服务器。毕竟,我在master和slaves上检查了jps,看起来都很好:master上的NameNode、SecondaryNameNode、ResourceManager;和DataNode,从服务器上的NodeManager。但是当我浏览到Hadoopma

  • 好日子,我有三个活动与它们相应的片段,和。片断是静态片断,其他片断是动态的。 活动已实现片段的侦听器,该侦听器用于以横向方向加载片段或在单个窗格中移动到新屏幕。 我想要的是,当按下fragment中的某个按钮(该按钮调用fragment)时,我想要在横向方向上用fragment替换(fragment仍然存在),或者在单窗格模式下打开新屏幕。我在activity B方法中有以下简单代码: 我试图避免

  • 这里是初学者。因此,对于我的类我在CSS中将顺序设置为-1,使其成为顶部的div。它正确地删除了类,但我假设前一个active的顺序仍然是-1 基本上我有:div1 div2 div3 div4 div5,如果用户点击其中一个,结果应该是div4 div1 div2 div3 div5 再次单击应该得到div2 div1 div3 div4 div5,但我得到的是div4 div2 div1 di

  • 会员营销 会员营销包括:评论、推广、点赞、注册、分享、签到、充值有礼。 一、评论:设置评论奖励规则。 点击进入评论页面: 可看到评价送积分、是否开启评论送优惠券的设置。 1、具体操作如下:(手机端) 第一步:点开会员中心——我的订单找到商品 第二步:点击我要评价,进行评价 第三步:点击发表,发表成功 第四步:在会员中心找到积分栏可查看到评论后所得积分 二、推广:会员推广设置。 点击进入会员推广页面

  • 尝试在magento 2.4中搜索产品时返回以下错误 异常#0(Elasticsearch\Common\Exceptions\NoNodes可用性异常):在集群中找不到活动节点 以下配置: PHP 7.4.1 Nginx 1.14 MySql 8 ElasticSearch 7.9 /etc/nginx/conf.d/100-magento2.conf /etc/nginx/conf.d/90-