当前位置: 首页 > 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

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


http://www.mrgr.cn/news/11755.html

相关文章:

  • 每日一问:GET请求和POST请求的区别
  • 仓颉语言:静态类型与垃圾收集,让编程更安全高效
  • 《JavaEE进阶》----2.<Spring前传:Maven项目管理工具>
  • 深入解析 Tomcat 的六大核心组件
  • Quartz定时任务
  • 项目策划书六度自由双足机器人
  • K-means算法原理及应用场景
  • 数学建模学习(119):基于R型聚类法与Q型聚类法的分类分析
  • nacos的配置更改了还要重启服务才生效
  • 李宏毅 机器学习与深度学习【2022版】 02
  • 【Leetcode 1876 】 长度为三且各字符不同的子字符串 —— 直接比较
  • AI学习记录 - 怎么理解 torch 的 torch.nn.BatchNorm2d
  • JavaScript 动画库
  • (最新)华为 2024 届秋招-硬件技术工程师-单板硬件开发—机试题—(共12套)(每套四十题)
  • 37 使用LDT(3)
  • 03_React 收集表单数据和 组件生命周期
  • 【Qt】容器类控件GroupBox
  • Python自动化办公2.0 课程更新
  • 切换JDK版本
  • Python邮箱发送如何配置SMTP服务发送邮件?