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

linux 安装kafaka单体服务

1.下载kafka的linux安装包

前往Apache Kafka官方网站下载页面(Apache Kafkahttps://kafka.apache.org/downloads),选择最新稳定版的Kafka二进制分发文件,通常是以`.tgz`结尾的文件。

手动下载kafka_2.13-3.8.0.tgz到本地,然后上传到linux服务器

2.解压Kafka

将下载的Kafka压缩包解压到一个合适的目录中,例如/usr/local

tar xzf kafka_2.13-3.1.0.tgz -C /usr/local/
cd /usr/local/

 解压后,你可能会看到一个新的目录,例如/usr/local/kafka_2.13-3.8.0

3. 配置Kafka

编辑/usr/local/kafka_2.13-3.8.0/config/server.properties文件来设置Kafka的配置。至少要修改broker.idlisteners属性以匹配你的环境。例如:

broker.id=0
listeners=PLAINTEXT://localhost:9092

如果要在集群中使用或者希望从外部访问,可能需要更改listeners为实际的IP地址和端口。

4.启动ZooKeeper和Kafka

Kafka依赖于ZooKeeper来管理集群状态。首先启动ZooKeeper,然后启动Kafka Broker。

进入Kafka安装目录下的bin目录:

cd /usr/local/kafka_2.13-3.8.0/bin/

启动ZooKeeper:

./zookeeper-server-start.sh /usr/local/kafka_2.13-3.8.0/config/zookeeper.properties &

启动Kafka Broker:

./kafka-server-start.sh /usr/local/kafka_2.13-3.8.0/config/server.properties &

 5.测试Kafka

为了确认一切正常工作,你可以创建一个主题并发送一些消息。创建一个主题:

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

向主题发送消息:

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

 接收消息:

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

 现在你可以输入消息并通过另一个终端窗口查看它们被消费。

相关文章:

  • 北京网站建设多少钱?
  • 辽宁网页制作哪家好_网站建设
  • 高端品牌网站建设_汉中网站制作
  • OD C卷 - Wonderland游乐园
  • 【第57课】SSRF服务端请求Gopher伪协议无回显利用黑白盒挖掘业务功能点
  • Maven的使用
  • 多线程面试常问
  • MarkDown演示
  • 【PostgreSQL教程】PostgreSQL 高级篇之触发器
  • 以简单的例子从头开始建spring boot web多模块项目(四)-多模块工具类
  • Android TableLayout中TextView文本不居中问题
  • 大数据-91 Spark 集群 RDD 编程-高阶 RDD广播变量 RDD累加器 Spark程序优化
  • FastAPI vs Flask: 专业对比与选择
  • 使用 setResponseStatus 函数设置响应状态码
  • Prometheus Operator部署管理
  • SQL每日一题-0823(难度提升题)
  • SpringCloud Gateway及 Springboot 服务 跨域配置
  • gcc: leaf function/non-leaf function;末节函数,叶子函数
  • 《网管员必读——网络组建》(第2版)电子课件下载
  • GraphQL学习过程应该是这样的
  • JavaScript 事件——“事件类型”中“HTML5事件”的注意要点
  • JavaScript异步流程控制的前世今生
  • Netty 4.1 源代码学习:线程模型
  • SAP云平台运行环境Cloud Foundry和Neo的区别
  • Spark RDD学习: aggregate函数
  • SpiderData 2019年2月13日 DApp数据排行榜
  • SQLServer之索引简介
  • 多线程 start 和 run 方法到底有什么区别?
  • 目录与文件属性:编写ls
  • 浅谈web中前端模板引擎的使用
  • 项目实战-Api的解决方案
  • 小程序button引导用户授权
  • 一、python与pycharm的安装
  • 一文看透浏览器架构
  • postgresql行列转换函数
  • 整理一些计算机基础知识!
  • #include
  • #职场发展#其他
  • (02)Cartographer源码无死角解析-(03) 新数据运行与地图保存、加载地图启动仅定位模式
  • (1)svelte 教程:hello world
  • (4)logging(日志模块)
  • (代码示例)使用setTimeout来延迟加载JS脚本文件
  • (附源码)springboot社区居家养老互助服务管理平台 毕业设计 062027
  • (附源码)springboot掌上博客系统 毕业设计063131
  • (附源码)ssm基于web技术的医务志愿者管理系统 毕业设计 100910
  • (黑马点评)二、短信登录功能实现
  • (六)c52学习之旅-独立按键
  • (区间dp) (经典例题) 石子合并
  • (原創) 如何動態建立二維陣列(多維陣列)? (.NET) (C#)
  • (转)负载均衡,回话保持,cookie
  • .NET / MSBuild 扩展编译时什么时候用 BeforeTargets / AfterTargets 什么时候用 DependsOnTargets?
  • .Net 6.0 处理跨域的方式
  • .Net Framework 4.x 程序到底运行在哪个 CLR 版本之上
  • .NET 应用架构指导 V2 学习笔记(一) 软件架构的关键原则
  • .net 怎么循环得到数组里的值_关于js数组
  • .Net插件开发开源框架
  • .NET开源的一个小而快并且功能强大的 Windows 动态桌面软件 - DreamScene2
  • 。Net下Windows服务程序开发疑惑