当前位置:首页 > 服务端 > centeros 7 安装kafka

centeros 7 安装kafka

2022年08月04日 19:48:08服务端4
centeros 安装kafka
1、官网 http://kafka.apache.org/downloads
   找到 Scala 2.13  - kafka_2.13-2.7.0.tgz (asc, sha512) 
   点击下载、上传至 /usr/local/kafka 下
2、解压:tar -zxvf kafka_2.13-2.7.0.tgz
3、创建两个文件夹分别存放 kafka数据 和zookeeper数据

centeros 7 安装kafka _ JavaClub全栈架构师技术笔记

4、修改配置文件
  ①zookeeper 配置文件 
  dataDir :改为保存数据的路径
  

centeros 7 安装kafka _ JavaClub全栈架构师技术笔记

②kafka配置文件 server.properties

centeros 7 安装kafka _ JavaClub全栈架构师技术笔记

继续编辑server.properties,添加对外暴露端口
#允许外部端口连接
listeners = PLAINTEXT://0.0.0.0:9092
#外部代理地址
advertised.listeners=PLAINTEXT://123.57.75.17:9092

5、守护线程启动 zookeeper
启动:
./bin/zookeeper-server-start.sh -daemon ./config/zookeeper.properties
关闭:
./bin/zookeeper-server-stop.sh ./config/zookeeper.properties 
6、启动kafka
启动:
./bin/kafka-server-start.sh -daemon ./config/server.properties
关闭:
./bin/kafka-server-stop.sh ./config/server.properties

7、测试 创建topic
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

解释:
所有和主题相关的操作基本./bin/kafka-topics.sh这个脚本,--create创建操作,--zookeeper localhost:2181指定zookeeper,--replication-factor指定主题副本数,--partitions 1指定主题分区数,--topic指定主题名称
8、
窗口1 生产者发消息:
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
解释:
./bin/kafka-console-producer.sh生产者相关的操作由此脚本执行,--broker-list参数指定了所使用的broker,--topic指定要往哪个主题发送消息

窗口2 消费者接收:
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
解释:
./bin/kafka-console-consumer.sh消费者相关的操作由此脚本执行,新版本的kafka使用--bootstrap-server参数,0.8版本以前消费进度是直接写到 zookeeper 的,consumer 必须知道 zookeeper 的地址。这个方案有性能问题,0.9 的时候整体大改了一次,brokers 接管了消费进度,consumer 不再需要和 zookeeper 通信了。--topic指定消费的主题,--from-beginning表示从分区开头进行消费,即重新消费全部消息
查看topic
./bin/kafka-topics.sh --zookeeper localhost:2181 --describe  --topic test
删除topic
./bin/kafka-topics.sh --zookeeper localhost:2181 --delete  --topic test

作者:锅锅嗨
来源链接:https://blog.csdn.net/weixin_43275578/article/details/121088333

版权声明:
1、JavaClub(https://www.javaclub.cn)以学习交流为目的,由作者投稿、网友推荐和小编整理收藏优秀的IT技术及相关内容,包括但不限于文字、图片、音频、视频、软件、程序等,其均来自互联网,本站不享有版权,版权归原作者所有。

2、本站提供的内容仅用于个人学习、研究或欣赏,以及其他非商业性或非盈利性用途,但同时应遵守著作权法及其他相关法律的规定,不得侵犯相关权利人及本网站的合法权利。
3、本网站内容原作者如不愿意在本网站刊登内容,请及时通知本站(javaclubcn@163.com),我们将第一时间核实后及时予以删除。


本文链接:https://www.javaclub.cn/server/17306.html

分享给朋友:

“centeros 7 安装kafka” 的相关文章

kafka入门及安装部署

kafka入门及安装部署

kafka入门及安装部署 kafka安装包下载 kafka简介及应用场景 简介 应用场景 kafka安装部署...

Kafka 安装和测试

Kafka 安装和测试

1. 简介 kafka (官网地址: http://kafka.apache.org)是一款分布式消息发布和订阅的系统,具有高性能和高吞吐率。 i. 消息的发布(publish)称作produ...

kafka启动后没反应

kafka使用脚本启动后后台没有进程 然后删除data和log目录下的所有文件 开启kafka,成功解决 作者:nidiquge 来源链接:https://blog.csdn.net/nidiquge/article/detail...

Windows环境中Kafka的安装及使用

Windows环境中Kafka的安装及使用

Kafka安装及使用 1. 简介 2.环境搭建 2.1安装JDK(例如JDK1.8等) 2.2 安装Zookeeper 2.3 安装Kafka...

docker安装kafka

docker安装kafka

1.先pull zookeeper的镜像 docker pull wurstmeister/zookeeper:latest docker pull wurstmeister/kafka:latest 2.查看镜像 docker im...

Kafka安装

Lison <cundream@163.com>, v1.0.3, 2019.03.27 摘要 解决和排查kafka安装过程中,由于kafka安装版本所使用zookeeper版本与本地zookeeper安装版本不兼容,导致kafk...

kafka安装步骤

kafka安装步骤

一、kafka介绍 1,kafka简单介绍 kafka是一款分布式、支持分区的、多副本,基于zookeeper协调的分布式消息系统。最大的特性就是可以实时处理大量数据来满足需求。 2,kafka使用场景 1,日志收集:可以用kafka收集各种服务的日志 ,...

centos8 kafka集群安装

##kafka运行涉及zookeeper,kafka和zookeeper都运行在jvm之上。 ###准备三台服务器,ip地址如下: 192.168.137.31 192.168.137.32 192.168.137.33 jdk安装 安...

windows安装kafka

windows安装kafka

一、下载kafka http://kafka.apache.org/downloads 选择二进制版本。 二、安装kafka 下载到本地后,将文件解压到本地磁盘下,该文件夹包括了所有相关的运行文件及配置文件,其子文件夹bin\w...

ubuntu安装kafka

我采用的是外部的zookeeper,而不是kafka自带的 如不知道安装zookeeper的参考:https://blog.csdn.net/weixin_36104843/article/details/80211404 1.下载 wget http...

发表评论

访客

◎欢迎参与讨论,请在这里发表您的看法和观点。