kafka启动和主题操作命令_启动kafka获取指定主题-程序员宅基地

技术标签: kafka  大数据  

  1. 启动kafka
    1. 启动 kafka自带的 zookeeper:
      在bin目录下: ./zookeeper-server-start.sh …/config/zookeeper.properties 1>/dev/null 2>&1 &(标注的这一句是为了不输出启动日志)

    2. 启动 kafka集群:
      (这里是伪分布式下的启动,加入-daemon以精灵线程启动,不打印日志)
      bin/kafka-server-start.sh -daemon config/server.properties &
      bin/kafka-server-start.sh -daemon config/server1.properties &
      bin/kafka-server-start.sh -daemon config/server2.properties &

    3. 关闭: sh kafka-server-stop.sh
      sh zookeeper-server-stop.sh

  2. Topic操作
    创建主题:
    1. 在bin目录下,
      ./kafka-topics.sh --create --zookeeper 主机名:端口号 --replication-factor 副本数 --partitions 分区数 --topic 主题名
      注意副本数不能大于broker的数量
    2. 显示主题列表:
      bin目录下
      ./kafka-topics.sh --list --zookeeper 主机名:zookeeper端口号
    3. 查看主题中消息详情:
      bin/kafka-topics.sh --describe --zookeeper 主机名:zookeeper端口号 --topic 主题名
    4. 开启一个生产者:
      ./kafka-console-producer.sh --broker-list 主机名:zookeeper端口号 --topic 主题名
    5. 消费主题上的消息:
      ./kafka-console-consumer.sh --bootstrap-server 主机名:zookeeper端口号 --topic 主题名 --from-beginning
      加上 --from-beginning 从头开始消费数据
      不加则默认消费最新的数据
版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/MK_Durry/article/details/106772376

智能推荐

b端 ux 设计思维_借助系统思维从视觉设计过渡到UX-程序员宅基地

文章浏览阅读279次。b端 ux 设计思维“How can I switch to UX?” This is a common question from visual designers because there’s a lot of overlap on the surface. But it can also be a difficult transition since UX encompasses much..._复杂系统的ux设计

php使用redis安装步骤,Windows下安装Redis、PHP安装Redis,PHP使用redis教程!-程序员宅基地

文章浏览阅读407次。【温馨提示】源码包解压密码:www.youhutong.comwindows下安装redis、PHP安装redis,PHP使用redis教程:1、下载redis和PHP扩展包:文章底部有下载连接!2、开始安装:1》安装redis:1、把下载下来的安装包解压到:(解压到什么地方都行)有32位的和64位,这个看你电脑操作系统!2、启动redis,测试redis:1、打开cmd命令进入到redis目录下..._phpstudy_pro启动redis

闽江学院c语言期末试卷,2008—2009学年第1学期闽江学院考试试卷(A)-程序员宅基地

文章浏览阅读175次。D)静态数据成员可以直接用类名调用14、下面对于友元函数描述正确的是A)友元函数的实现必须在类的内部定义B)友元函数是类的成员函数C)友元函数破坏了类的封装性和隐藏性D)友元函数不能访问类的私有成员15、在公有派生情况下,有关派生类对象和基类对象的关系,下列叙述不正确的是A)派生类的对象可以赋给基类的对象B)派生类的对象可以初始化基类的引用C)派生类的对象可以直接访问基类中的成员D)派生类的对象的..._闽江学院公共课c语言期末试卷

【学习笔记】操作系统&计算机网络&Linux运维&常用组件_常见linux运维组件-程序员宅基地

文章浏览阅读204次。【学习笔记】操作系统&计算机网络&Linux运维&常用组件_常见linux运维组件

卡内基梅隆 计算机音乐,包揽大牛|CMU Music tech也来了!!大牛横扫了!!-程序员宅基地

文章浏览阅读428次。原标题:包揽大牛|CMU Music tech也来了!!大牛横扫了!!NutsCongratulationsNuts北大学员横扫了!继QueenMary博士/Gatech/NYU/Mcgill硕士后最dream的顶尖CMU music tech拿下Offer CMU 卡内基·梅隆大学(Carnegie Mellon University),简称CMU,坐落在美国宾夕法尼亚州的匹兹堡,是一所拥有..._cmu ai+music

asp文件怎么转换成html代码,将asp页面转换成html页面 代码-程序员宅基地

文章浏览阅读80次。该楼层疑似违规已被系统折叠隐藏此楼查看此楼将asp页面转换成html页面SubGenFile(id)dimobjXmlHttpsetobjXmlHttp=Server.CreateObject("Microsoft.XMLHTTP")objXmlHttp.open"GET","http://www.xxx.com/product.asp?id="&id,falseobj..._as2文件转换为html

随便推点

【Python】求导数,利用 scipy 库求导数_python derivative函数-程序员宅基地

文章浏览阅读1w次,点赞4次,收藏29次。利用Python求导数scipy.misc.derivativescipy.misc.derivative(func, x0, dx=1.0, n=1, args=(), order=3)Parameters:func: functionInput function.x0: floatThe point at which n-th derivative is found...._python derivative函数

cs计算机科学 文书,【DIY教程】美国CS专业计算机工程申请指南(76所院校录取详细数据+排名+面经+文书范文)...-程序员宅基地

文章浏览阅读368次。1、美国计算机工程专业介绍、如何选校、各项考试的准备2、美国165所综合性大学中开设计算机工程专业的院校,收集的信息包括综合排名,学校名称,专业(中英文名称),开设学位等)3、76所开设计算机工程专业的美国院校录取要求(本科专业要求、截止日期、托福/雅思、GRE及GPA要求,以及其他重要信息)4、USNEWS美国计算机科学专业排名5、美国计算机工程专业面经6、CS文书写作教程及模板小库需要提醒各位..._cs研究生申请文书

CSPDarkNet53学习-程序员宅基地

文章浏览阅读3.4w次。文章目录CSP结构Applying CSPNet to ResNe(X)tApplying CSPNet to DenseNetDarkNet53介绍CSPDarknet53架构参考CSP结构Applying CSPNet to ResNe(X)t原文如此介绍:设计出Partial transition layers的目的是最大化梯度联合的差异。其使用梯度流截断的手段避免不同的层学习到重复的梯度信息。得出的结论是,如果能够有效的减少重复的梯度学习,那么网络的学习能力能够大大提升.Applying _cspdarknet53

只需半分钟,ARMS 帮你配置出“高质量”告警-程序员宅基地

文章浏览阅读215次。背景Aliware某位资深运维工程师A:“一天不收个几十条告警,我都觉得心里不踏实” 。运维工程师B:“我那几个告警天天告,我的应用一点问题都没有,但是我又不敢关”。运维工程师C:“我每天都要花大量的时间,整理已经发生的告警:查它们是什么原因导致的,是故障还是误报,要不要解决,要不要屏蔽。”运维工程师D:“要不我们给告警数配置一个告警吧,一天收100条告警是正常的,哪天告出来200条估计就是有问题..._运维系统 报警配置

基于ZigBee的工业废气监测系统_基于zigbee的工业废气检测系统-程序员宅基地

文章浏览阅读1.1w次,点赞14次,收藏109次。基于ZigBee的工业废气监测系统摘 要本文主要对工业现场中排放的工业废气浓度进行检测。并根据国内外气体监测技术的发展现状,提出了基于ZigBee的工业废气监测系统的设计方案。本系统主要由单片机、气体浓度检测模块、模数转换模块、显示模块、按键、蜂鸣器和无线通信模块等组成。本文首先介绍了工业废气检测系统的研究背景意义,同时结合国内外气体检测技术的发展现状,提出了基于ZigBee的工业废气监测..._基于zigbee的工业废气检测系统

CircularSlider半弧形滑动条-程序员宅基地

文章浏览阅读476次。前言这边文章主要 是写一、半圆弧型滑块的设计最近项目中需要用到半圆弧形滑块,其作用和UISlider差不多,用于拖动改变播放音乐的播放进度。大概样子是这样的:效果展示特点如下:滑动响应区域为弧环上,并且靠近滑动块,,并限制了中心区域不可滑动;当值为0时不可再逆时针滑动,当值为最大值时,不再可顺时针..._ios 排除点在圆外面点与圆心半径