Linux:【Kafka二】基础命令_linux kafka发送消息,看完阿里P9大牛的“Linux运维成长笔记”我悟了
创始人
2024-11-05 12:07:26
0

先自我介绍一下,小编浙江大学毕业,去过华为、字节跳动等大厂,目前阿里P7

深知大多数程序员,想要提升技能,往往是自己摸索成长,但自己不成体系的自学效果低效又漫长,而且极易碰到天花板技术停滞不前!

因此收集整理了一份《2024年最新Linux运维全套学习资料》,初衷也很简单,就是希望能够帮助到想自学提升又不知道该从何学起的朋友。
img
img
img
img
img

既有适合小白学习的零基础资料,也有适合3年以上经验的小伙伴深入学习提升的进阶课程,涵盖了95%以上运维知识点,真正体系化!

由于文件比较多,这里只是将部分目录截图出来,全套包含大厂面经、学习笔记、源码讲义、实战项目、大纲路线、讲解视频,并且后续会持续更新

如果你需要这些资料,可以添加V获取:vip1024b (备注运维)
img

正文

Linux内核:Centos7

Kafka版本:3.5.1

执行命令的目录位置:Kafka安装目录的bin目录下:/usr/local/kafka/bin/

一、操作主题命令

1.1.创建主题

./kafka-topics.sh --bootstrap-server localhost:9092  --create  --topic mytesttopic 

1.2.指定主题的分区数、副本数创建主题

./kafka-topics.sh --bootstrap-server localhost:9092  --create   --replication-factor 1 --partitions 1 --topic mytesttopic 

1.3.查看kafka中的主题列表信息

./kafka-topics.sh --bootstrap-server localhost:9092 --list  

1.4.查看kafka找那个特定主题的详细信息

./kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic mytesttopic  

1.5.修改主题的分区数(只能从小往大改)

./kafka-topics.sh --bootstrap-server localhost:9092 --alter --topic mytesttopic --partitions 2 

1.6.删除主题

./kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic mytesttopic 

二、操作消息命令

2.1.生产者向指定主题发送消息

./kafka-console-producer.sh broker-list --bootstrap-server localhost:9092  --topic mytesttopic  ## 下面为提示的消息输入框 >send message 1 >send message 2 

2.2.消费者监听指定消息(消费者每次启动都从主题中最开始的消息开始监听)

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mytesttopic --from-beginning 

2.3.消费者监听指定主题的消息(消费者每次启动都从最新的消息开始监听)

注意:该监听方式,如果消费者想监听到消息,那么需要在消费者监听成功后,再使用命令让生产者发送消息

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testtopic0914 

三、消费者组操作命令

3.1.创建一下消费者监听消息,并将该消费者放在名为testgroup消费者组下

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --consumer-property group.id=testgroup --topic testtopic0914 

3.2.查看消费者组列表

./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list 

3.3.查看消费者组的详细信息

./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group testgroup 

消费者组中的各项列表含义如下:

GROUP:消费者组名称
      TOPIC:消费者组监听的消息
      PARTITON:使用的是第几个分区
      CURRENT-OFFSET:当前消息的偏移量
      LOG-END-OFFSET:消费的偏移量
      LAG:还有多少消费没有被消费,即积压的消息数
 3.4.删除消费者组

./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --delete --group {消费组} 

四、kafka集群中操作消息的命令

4.1.向集群中发送消息

[root@localhost kafka_2.12-3.5.1]# ./bin/kafka-console-producer.sh  --broker-list 192.168.154.128:9092,192.168.154.128:9093,192.168.154.128:9094 --topic topic0921  

4.2.消费者消费消息(未指定消费组)

为了做好运维面试路上的助攻手,特整理了上百道 【运维技术栈面试题集锦】 ,让你面试不慌心不跳,高薪offer怀里抱!

这次整理的面试题,小到shell、MySQL,大到K8s等云原生技术栈,不仅适合运维新人入行面试需要,还适用于想提升进阶跳槽加薪的运维朋友。

本份面试集锦涵盖了

  • 174 道运维工程师面试题
  • 128道k8s面试题
  • 108道shell脚本面试题
  • 200道Linux面试题
  • 51道docker面试题
  • 35道Jenkis面试题
  • 78道MongoDB面试题
  • 17道ansible面试题
  • 60道dubbo面试题
  • 53道kafka面试
  • 18道mysql面试题
  • 40道nginx面试题
  • 77道redis面试题
  • 28道zookeeper

总计 1000+ 道面试题, 内容 又全含金量又高

  • 174道运维工程师面试题

1、什么是运维?

2、在工作中,运维人员经常需要跟运营人员打交道,请问运营人员是做什么工作的?

3、现在给你三百台服务器,你怎么对他们进行管理?

4、简述raid0 raid1raid5二种工作模式的工作原理及特点

5、LVS、Nginx、HAproxy有什么区别?工作中你怎么选择?

6、Squid、Varinsh和Nginx有什么区别,工作中你怎么选择?

7、Tomcat和Resin有什么区别,工作中你怎么选择?

8、什么是中间件?什么是jdk?

9、讲述一下Tomcat8005、8009、8080三个端口的含义?

10、什么叫CDN?

11、什么叫网站灰度发布?

12、简述DNS进行域名解析的过程?

13、RabbitMQ是什么东西?

14、讲一下Keepalived的工作原理?

15、讲述一下LVS三种模式的工作过程?

16、mysql的innodb如何定位锁问题,mysql如何减少主从复制延迟?

17、如何重置mysql root密码?

网上学习资料一大堆,但如果学到的知识不成体系,遇到问题时只是浅尝辄止,不再深入研究,那么很难做到真正的技术提升。

需要这份系统化的资料的朋友,可以添加V获取:vip1024b (备注运维)
img

一个人可以走的很快,但一群人才能走的更远!不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人,都欢迎加入我们的的圈子(技术交流、学习资源、职场吐槽、大厂内推、面试辅导),让我们一起学习成长!
一大堆,但如果学到的知识不成体系,遇到问题时只是浅尝辄止,不再深入研究,那么很难做到真正的技术提升。**

需要这份系统化的资料的朋友,可以添加V获取:vip1024b (备注运维)
[外链图片转存中…(img-mv9RDWlI-1713376022471)]

一个人可以走的很快,但一群人才能走的更远!不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人,都欢迎加入我们的的圈子(技术交流、学习资源、职场吐槽、大厂内推、面试辅导),让我们一起学习成长!

相关内容

热门资讯

黑科技辅助(红龙扑克功能)外挂... 黑科技辅助(红龙扑克功能)外挂透明挂辅助软件(透视)固有有挂(2022已更新)(哔哩哔哩)是一款可以...
推荐一款!乐乐安徽麻将挂管用(... 推荐一款!乐乐安徽麻将挂管用(辅助挂)从来真的是有挂(有挂秘笈)-哔哩哔哩;1、点击下载安装,乐乐安...
重大推荐(Wepoke打法)一... 您好,Wepoke打法这款游戏可以开挂的,确实是有挂的,需要了解加微【136704302】很多玩家在...
必备辅助推荐(WePoKe下载... 必备辅助推荐(WePoKe下载)外挂透明挂辅助工具(Wepoke)系统机制(其实真的有挂)-哔哩哔哩...
黑科技辅助(悟空德州正规)外挂... 黑科技辅助(悟空德州正规)外挂透明挂辅助工具(透视)切实是有挂(2022已更新)(哔哩哔哩);一、悟...
今日重大通报!乐享牛牛有挂(辅... 今日重大通报!乐享牛牛有挂(辅助挂)从来存在有挂(有挂方式)-哔哩哔哩;乐享牛牛有挂软件透明挂是一个...
信息共享(WePoKe插件安装... 您好,WePoKe插件安装这款游戏可以开挂的,确实是有挂的,需要了解加微【485275054】很多玩...
总算了解(AAPoKer介绍)... 总算了解(AAPoKer介绍)外挂透明挂辅助软件(wepoke)有挂(本来真的是有挂)-哔哩哔哩;1...
黑科技辅助(fishpoker... 黑科技辅助(fishpoker有挂)外挂透明挂辅助挂(透视)素来是真的有挂(2025已更新)(哔哩哔...
实测发现!河洛杠次外挂(辅助挂... 实测发现!河洛杠次外挂(辅助挂)果然真的是有挂(确实有挂)-哔哩哔哩;1、这是跨平台的河洛杠次外挂黑...