当前位置: 首页 > news >正文

ubuntu安装kafka(无zk版本)

安装包下载

去官网下载最新安装包:https://kafka.apache.org/downloads

解压安装包

tar -xzvf kafka_2.13-3.9.1.tgz

 

安装及配置

修改日志文件存放路径

 vim config/kraft/server.properties

生成集群id

输出id后保存一下

sh kafka-storage.sh random-uuid

格式化目录

sh ./kafka-storage.sh format -t ${your_id} -c /home/cheers/softpkg/kafka_2.13-3.9.1/config/kraft/server

 把刚才生成的id替换到your_id变量上

格式化操作完成之后,你会发现在我们定义的log.dirs目录下多出一个meta.properties文件。meta.properties文件中存储了当前的kafka节点的id(node.id),当前节点属于哪个集群(cluster.id

启动kafka服务

使用以下命令启动kafka服务,不要关闭

 ./bin/kafka-server-start.sh ./config/kraft/server.properties

测试

创建topic

新开一个终端,创建名为test_topic的Topic

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

 如果输出以下内容说明创建成功

Created topic test_topic.

查看创建的topic

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

 如果输出test_topic再次说明创建成功

生产消息

接下来使用创建的topic生产消息

bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test_topic

使用上述命令会进入交互式终端,然后输入你想要发送的消息,比如

 

消费消息

接下来再次新开一个终端,创建消费者,观察是否可以接收刚才生产者生产的消息

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

此时如果在生产者终端的交互式界面键入信息,你会发现消费者终端也会实时显示发送的消息 

http://www.dtcms.com/a/278494.html

相关文章:

  • Leaflet面试题及答案(81-100)
  • linux打包固件shell脚本
  • 打开xmind文件出现黑色
  • 理解Linux文件系统:从物理存储到统一接口
  • 【第一章编辑器开发基础第二节编辑器布局_3GUI元素和布局大小(3/4)】
  • 一般的非线性规划求解(非凸函数)
  • 自定义类型 - 联合体与枚举(百度笔试题算法优化)
  • 《C++初阶之STL》【泛型编程 + STL简介】
  • Spring原理揭秘--初识AOP
  • Spring 学习笔记
  • UI前端大数据处理新挑战:如何高效处理实时数据流?
  • JavaScript 与 C语言基础知识差别
  • GO语言中的垃圾回收(GC)
  • 怎么挑选最新贝琪入门电钢琴才高效?
  • Java进程、线程与协程对比
  • GD32/STM32嵌入CMSIS-DSP的库(基于Keil)
  • 2025年 GitHub 主流开源视频生成模型介绍
  • Go语言第一个程序--hello world!
  • arthas:Java 应用问题诊断利器
  • 企业培训笔记:axios 发送 ajax 请求
  • vue中计算属性的介绍
  • 前端基础知识TypeScript 系列 - 08(TypeScript 装饰器的理解)
  • 代理模式详解:代理、策略与模板方法模式
  • SpringMVC1
  • GraphRAG核心提示词工程完整中文版
  • VyOS起步指南:用Docker快速搭建网络实验环境
  • 分享三个python爬虫案例
  • HTML应用指南:利用GET请求获取河南省胖东来超市门店位置信息
  • STM32新建工程
  • HTB 赛季8靶场 - Outbound