当前位置：主页 > 查看内容

Linux下kafka入门基础：启动、生产与消费

发布时间：2021-05-16 00:00| 有 位朋友查看

简介：文章目录 一、启动 1.启动Zookeeperzk 2.启动Kafka 二、生产与消费 1.创建topic 2.生产消息 3.消费消息 总结 提示这里Kafka的版本是kafka_2.12-2.7.0。因Kafka没有提供version的命令要查看版本可以进入到kafka/libs/目录下可以看到像kafka_2.12-2.7.0.jar这……

文章目录

提示：这里Kafka的版本是kafka_2.12-2.7.0。因Kafka没有提供version的命令，要查看版本可以进入到kafka/libs/目录下，可以看到像kafka_2.12-2.7.0.jar这样的文件，其中2.12是Scala版本，2.7.0是Kafka版本。

一、启动

下面启动命令都是在Kafka根目录下执行

cd /home/kafka/

1.启动Zookeeper（zk）

因为Kafka依赖于zk所以先启动zk
这里没有单独安装过zk用的是kafka/bin目录下自带的

nohup ./bin/zookeeper-server-start.sh ./config/zookeeper.properties &

成功会返回进程号
在这里插入图片描述

也可以通过端口号查看状态

netstat -tunlp | grep 2181

在这里插入图片描述

2.启动Kafka

nohup ./bin/kafka-server-start.sh ./config/server.properties &

成功会返回进程号
在这里插入图片描述

二、生产与消费

1.创建topic

创建topic并命名为mytopic

./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mytopic

成功后会返回：Created topic mytopic.
在这里插入图片描述
查看下创建的所有topic

./bin/kafka-topics.sh --list --zookeeper localhost:2181

在这里插入图片描述

2.生产消息

./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mytopic

这里写两条消息测试下（Ctrl+c可以退出）
在这里插入图片描述

3.消费消息

另开一个窗口来消费信息

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

成功消费到
在这里插入图片描述
最后看看效果
在这里插入图片描述

总结

以上就是Linux下Kafka基本功能的实现，期待各位同僚对本文进行点评！

；原文链接：https://blog.csdn.net/z1761419224/article/details/115464544
本站部分内容转载于网络，版权归原作者所有，转载之目的在于传播更多优秀技术内容，如有侵权请联系QQ/微信：153890879删除，谢谢！
上一篇：Excel数据分析系列之用好底层分析工具统计分析功能 下一篇：Elasticsearch：消除 Elasticsearch 中的重复数据

推荐图文

  • 周排行
  • 月排行
  • 总排行

随机推荐