千家信息网

Linux系统如何安装Kafka

发表于:2026-11-02 作者:千家信息网编辑
千家信息网最后更新 2026年11月02日,小编给大家分享一下Linux系统如何安装Kafka,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!Kafka是一种高吞吐量的
千家信息网最后更新 2026年11月02日Linux系统如何安装Kafka

小编给大家分享一下Linux系统如何安装Kafka,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!

Kafka是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者在网站中的所有动作流数据。

Kafka简介:

Kafka是一个分布式消息队列。★Kafka对消息保存时根据Topic进行归类,发送消息者称为Producer,消息接受者称为Consumer,此外kafka集群有多个kafka实例组成,每个实例(server)称为broker。无论是kafka集群,还是consumer都依赖于zookeeper集群保存一些meta信息,来保证系统可用性。

Linux系统安装Kafka具体步骤:

Kafka下载 官网下载地址 http://kafka.apache.org/downloads demo用的版本 https://archive.apache.org/dist/kafka/1.0.0/kafka_2.12-1.0.0.tgz

解压到安装目录下 tar -zxvf kafka_2.12-1.0.0.tgz mv kafka_2.12-1 /usr/local/kafka

配置 #创建日志存放目录,默认Kafka运行的时候都会通过log4j打印很多日志文件,比如server.log, controller.log, state-change.log等,而都会将其输出到$KAFKA_HOME/logs目录下,这样不利于线上运维,因为经常容易出现打爆文件系统

 #这里我们把日志目录指向var目录下 cd /var/local mkdir -p kafka-logs  #修改配置文件/opt/kafka/config/server.properties vi /usr/local/kafka/config/server.properties  #主要修改下面几项内容如下:

broker.id=181 delete.topic.enable=true listeners = PLAINTEXT://192.168.0.166:9092 log.dirs=/var/local/kafka-logs zookeeper.connect=127.0.0.1:2181

添加系统环境变量 vi /etc/profile #添加如下内容:

KAFKA_HOME=/usr/local/kafka PATH=KAFKA_HOME/bin export PATH KAFKA_HOME

启动、测试 kafka-server-start.sh /usr/local/kafka/config/server.properties #发送 ./kafka-console-producer.sh –broker-list 192.168.0.166:9092 –topic test1 #接收 ./kafka-console-consumer.sh –zookeeper 192.168.0.166:2181 -topic test1 –from-beginning

开机启动 #在init.d目下创建kafka脚本文件

 cd /etc/rc.d/init.d  touch kafka  vi kafka

#编辑下面内容

#!/bin/bash

#chkconfig:2345 30 80 #description:kafka #processname:kafka export JAVA_HOME=/usr/local/jvm/jdk1.8.0_201 export KAFKA_HOME=/usr/local/kafka case {KAFKA_HOME}/bin/kafka-server-start.sh -daemon {KAFKA_HOME}/bin/kafka-server-stop.sh ;; status) jps ;; restart) {KAFKA_HOME}/bin/kafka-server-start.sh -daemon ${KAFKA_HOME}/config/server.properties ;; *) echo "require start|stop|status|restart" ;; esac #权限

 chmod 755 kafka  #测试一下  service kafka start  #添加到服务列表  chkconfig --add kafka  chkconfig --list  chkconfig kafka on

遇到的坑 Kafka进程总是在启动一段时间后自动停止 使用-daemon守护进程启动 kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties

以上是"Linux系统如何安装Kafka"这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注行业资讯频道!

系统 内容 消息 目录 文件 日志 篇文章 集群 分布式 实例 进程 测试 配置 不怎么 动作 变量 可用性 吞吐量 地址 多个 数据库的安全要保护哪些东西 数据库安全各自的含义是什么 生产安全数据库录入 数据库的安全性及管理 数据库安全策略包含哪些 海淀数据库安全审计系统 建立农村房屋安全信息数据库 易用的数据库客户端支持安全管理 连接数据库失败ssl安全错误 数据库的锁怎样保障安全 广州大一互联网络科技有限公司 互联网科技有限公司图片 互联网 的科技创新 奇酷互联网科技 紫鲸互联网科技 万达互联网科技 互联网科技视频素材 滨湖区互联网智能科技产品供应 无锡溥仪互联网科技有限公司 湖南洣水互联网科技有限公司扣款 西藏七维空间互联网科技有限公司 崇明区互联网教育科技售后服务 美国互联网科技实力 广东工业互联网大赛深圳学泰科技 皮皮虾互联网科技有限公司 半导体是互联网高科技吗 上海互联网科技公司ppt 互联网科技企业商标注意事项 唯美互联网科技 广州全民伙伴互联网科技有限公司 互联网科技垄断 互联网络科技有限公司 杭州互联网科技公司 中国互联网科技发展 互联网科技论文 西安互联网科技公司 甘肃拓世互联网科技有限公司 成都铂石互联网科技做什么的 广州千川互联网科技有限公司 盐城市攀科互联网科技有限公司
0