大数据技术之kafka (第 3 章 Kafka 架构深入 ) 消费者组案例

1)需求:测试同一个消费者组中的消费者,同一时刻只能有一个消费者消费。 
2)案例实操 
 (1)在 backupo01、backupo02 上修改/usr/local/hadoop/kafka/kafka_2.12-2.4.1/config/consumer.properties 配置
文件中的 group.id 属性为任意组名。 

[root@backup01 config]$ vim consumer.properties group.id=yuwenlong

(2)在 backup01、backup02 上分别启动消费者

[root@backup01 kafka_2.12-2.4.1]$ bin/kafka-console-consumer.sh --bootstrap-server backup01:9092 --topic bigdata --consumer.config config/consumer.properties [root@backup02 kafka_2.12-2.4.1]# bin/kafka-console-consumer.sh --bootstrap-server backup01:9092 --topic bigdata --consumer.config config/consumer.properties

查看下消费者组(已经有一个消费者组yuwenlong)

(3)在 backup03 上启动生产者

[root@backup03 kafka_2.12-2.4.1]$ bin/kafka-console-producer.sh --broker-list backup03:9092 --topic bigdata 

这里我直接在backup01启动生产者,发送了两条数据  (启动backup03也是一样的)

其中一个消费者(消费了hello):

另一个消费者(消费了atguigu)

(4)查看 backup01 和 backup02 的接收者。 (上面已经查看过了)
  证实: 同一时刻只有一个消费者接收到消息。 

下面这里启动backup03生成者

 消费了hello world

 消费了yuwenlong how are you

再次证明了  同一时刻只有一个消费者接收到消息

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/576446.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Easyui弹出窗口在iframe中弹出被当前iframe遮罩的问题(解决方法)

例如我们点击一个按钮&#xff0c;然后弹出我们需要的Window控件窗口。 1 //点击按钮2 var _testWindow window.top.$(testWindow);3 $(#testButton).click(function(){4 if(_testWindow.length < 0) {5 _testWindow window.top.$("<div idtestWin…

JDK1.8中String类的intern()方法学习

jdk1.8字符串常量池是位于堆中&#xff1b; 在jdk1.8中使用如下指令时会同时在堆中和常量池&#xff08;前提是常量池中还没有该对象&#xff09;中创建字符串对象&#xff0c;但是s是指向堆中。 String s new String("HELLO"); 如下方法会判断常量池中是否存在s,…

sfs2x 连接 mongodb

void initMongodb() {Mongo mongo;try {trace("\ninitMongodb\n");mongo new Mongo("localhost", 10011);DB db mongo.getDB("yourdb");// 从Mongodb中获得名为yourColleection的数据集合&#xff0c;如果该数据集合不存在&#xff0c;Mongodb…

大数据技术之kafka (第 3 章 Kafka 架构深入 ) 高效读写数据

1&#xff09;顺序写磁盘 Kafka 的 producer 生产数据&#xff0c;要写入到 log 文件中&#xff0c;写的过程是一直追加到文件末端&#xff0c; 为顺序写。官网有数据表明&#xff0c;同样的磁盘&#xff0c;顺序写能到 600M/s&#xff0c;而随机写只有 100K/s。这 与磁盘的机…

设计模式参考博客

http://www.cnblogs.com/zhenyulu/category/6930.html 吕震宇的博客园&#xff0c;关于设计模式介绍的比较全面。很值得学习的博客转载于:https://www.cnblogs.com/wangzihao/archive/2012/05/23/2514485.html

大数据技术之kafka (第 3 章 Kafka 架构深入) Zookeeper 在 Kafka 中的作用

Kafka 集群中有一个 broker 会被选举为 Controller&#xff0c;负责管理集群 broker 的上下线&#xff0c;所有 topic 的分区副本分配和 leader 选举等工作。 Controller 的管理工作都是依赖于 Zookeeper 的。 以下为 partition 的 leader 选举过程&#xff1a; Leader选举流…

SQLServer优化二

建立合理的索引,避免扫描多余数据&#xff0c;避免表扫描&#xff01;几百万条数据&#xff0c;照样几十毫秒完成查询。关于SQL查询效率&#xff0c;100w数据&#xff0c;查询只要1秒&#xff0c;与您分享&#xff01; 查询效率分析&#xff1a; 子查询为确保消除重复值&#x…

大数据技术之kafka (第 3 章 Kafka 架构深入) Kafka 事务

Kafka 从 0.11 版本开始引入了事务支持。事务可以保证 Kafka 在 Exactly Once 语义的基础上&#xff0c;生产和消费可以跨分区和会话&#xff0c;要么全部成功&#xff0c;要么全部失败 3.6.1 Producer 事务 为了实现跨分区跨会话的事务&#xff0c;需要引入一个全局唯一的 T…

JasperReport里面的Demo

1. alterdesign 该例子演示了报表编译后&#xff0c;在报表展现的时候如何动态的控制其中的元素比如让某一个矩形变色或其他 2. antcompile 演示如何让 ant 来编译 3. chart 演示了如何在报表中添加图像&#xff0c;JasperReport是用Scriptlet的方式往报表中添加图像&#xff0…

LinkedList源码阅分析

LinkedList里面涉及到的一些操作&#xff0c;非常细致&#xff0c;以避免出现的空指针&#xff0c;理解后对于其优点与确定会有一个更加整体的认识吧。 继承关系图(对比ArrayList) 元素的存储结构 在LinkedList中&#xff0c;每一个元素都是Node存储&#xff0c;Node拥有一个存…

Windows Azure Marketplaces上的Bing Search API可用啦!

Windows Azure Marketplace上的Bing Search API 现在可用啦&#xff01;通过此服务&#xff0c;你可以嵌入web、图像、新闻和视频搜索结果&#xff0c;以及相关的搜索和拼写建议来创建独特的应用程序和服务。 你也可以将数据集里的信息通过标准化的数据服务整合到应用程序中&am…

取消选中目标CALL

事先在游戏里选中一个怪物bp send,回到游戏里,按ESC&#xff0c;OD断下来,复制 返回到 elementc.072AFDD8 005869B2 返回到 elementc.005869B2 来自 elementc.0058E8A0072AFDEC 00588B1F 返回到 elementc.00588B1F 来自 elementc.00586980072AFE28 005A7346 返回到 el…

《深入理解java虚拟机》第1章 走近Java

1.6实战:自己编译JDK 想要一探JDK内部的实现机制&#xff0c;最便捷的路径之一就是自己编译- -套JDK,通过阅读和跟踪调试JDK源码去了解Java技术体系的原理&#xff0c;虽然门槛会高一点&#xff0c;但肯定会比阅读各种书籍、文章更加贴近本质。另外&#xff0c;JDK中的很多底层…

【XDA汉化组编写】Android软件汉化/精简/去广告/优化教程 FAQ

* 引用、转载请注明出处&#xff1a;XDA智能手机论坛-bbs.xda.cn-iKira&#xff01; http://bbs.xda.cn/thread-10968699-1-1.html* 汉化其实不难&#xff0c;难的是持之以恒&#xff0c;祝各位机友学有所得。转载于:https://www.cnblogs.com/dongzhiquan/archive/2012/05/30/2…

《深入理解java虚拟机》第2章 Java内存区域与内存溢出异常

Java与C之间有一堵由内存动态分配和垃圾收集技术所围成的“高墙”&#xff0c;墙外面的人想进去&#xff0c;墙里面的人却想出来。 2.1 概述 https://blog.csdn.net/q5706503/article/details/84640762 对于从事C、C程序开发的开发人员来说&#xff0c;在内存管理领域&#…

管理学习(2)——职场中最重要的四件事

职场中最重要的四件事职场的核心精髓可以概括为职场中最重要的三件事&#xff0c;它们分别是&#xff1a;职场第一要务、职业化、职场的本质。 1.这三件事与身处职场的我们到底有什么关系呢&#xff1f; 就让我用三句话概括一下&#xff1a; 职场第一要务决定了我们在职场上的…

国内科技博客盘点

自从TechCrunch在2010年被AOL以三千万美金收购以后&#xff0c;国内的科技博客风起云涌&#xff0c;引起一股不小的科技博客热&#xff0c;至今为止&#xff0c;已是你方唱罢我登场&#xff0c;好不热闹&#xff0c;让我们来盘点一下国内近些年冒出来的一些比较知名的科技博客&…

线性表的定义和基本运算之线性结构

一、线性表的逻辑定义和性质 线性表是最简单和最常用的一种数据结构&#xff0c;他是由n个数据元素&#xff08;结点&#xff09;a1,a2,a3,a4........an组成的有限序列。其中&#xff0c;数据元素个数那位表的长度。当n为0时称为空表&#xff0c;非空的线性表通常记为 &#x…

TForm1*Form1=newTForm1(this); Form1-Show();

TForm1*Form1newTForm1(this);Form1->Show();通过 Wiz 发布转载于:https://www.cnblogs.com/xe2011/archive/2012/06/03/2532874.html

[科研笔记] 关于人工智能与算法项目的思考

原链接&#xff1a;https://blog.csdn.net/walilk/article/details/77131929 前言   [科研笔记] 系列是我在科研道路上的随笔和思考&#xff0c;内容不加以局限&#xff0c;是一个开放的文章系列&#xff0c;这也是给自己一点自由的空间。      本文是我结合自身经验给的…