当前位置:首页 > 服务端 > kafka的安装与使用

kafka的安装与使用

2022年08月05日 22:00:28服务端2

(1) kafka下载

下载地址:https://kafka.apache.org/downloads
kafka的安装与使用 _ JavaClub全栈架构师技术笔记
说明:
sourcre downloads(源代码下载)下载以后需要自行编译出安装包,再行安装。
Binary downloads(二进制下载)已经编译完成的安装包,下载之后可以直接安装使用。Scala的版本不同,对应的kafka版本也不一样。

我是用的是2.1.12-3.0.0。网盘下载链接: https://pan.baidu.com/s/1lVoCGLY_ogT5QWskH0yNjw 密码: fppw

(2) 解压安装

Centos解压命令: tar-zxvf xxxxxxxxx.tgz
kafka的安装与使用 _ JavaClub全栈架构师技术笔记
解压后的文件内部:
kafka的安装与使用 _ JavaClub全栈架构师技术笔记
配置文件夹内部:
kafka的安装与使用 _ JavaClub全栈架构师技术笔记

(3) 修改配置

我当前采用的是单机版本的kafka。所以broker.id可以任意设置,一定不会重复。

修改配置,具体来说是解压目录下的config/server.properties:broker.id、log.dirs

vim server.properties	//修改配置

修改日志文件的存储位置
kafka的安装与使用 _ JavaClub全栈架构师技术笔记

(4)启动kafka

1、启动zookeeper

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties //启动zookeeper

kafka的安装与使用 _ JavaClub全栈架构师技术笔记

2、启动kafka server

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

启动之后,就停在下面的页面。打开新的命令行窗口进行测试即可。
kafka的安装与使用 _ JavaClub全栈架构师技术笔记

3、创建topic

 bin/kafka-topics.sh --create --bootstrap-server localhost:9092 
 --replication-factor 1 --partitions 1 --topic second-kafka-topic  //second-kafka-topic是创建的topic的名称

kafka的安装与使用 _ JavaClub全栈架构师技术笔记

4、查看topic

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

kafka的安装与使用 _ JavaClub全栈架构师技术笔记

5、启动consumer

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

kafka的安装与使用 _ JavaClub全栈架构师技术笔记

启动之后,命令行窗口就停在这里等待消费消息。

6、启动producer

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

在生产者console启动后,会出现箭头提示。可以输入消息。
kafka的安装与使用 _ JavaClub全栈架构师技术笔记

输入消息之后,可以在消费者的命令行中看到生产者生产的消息。
kafka的安装与使用 _ JavaClub全栈架构师技术笔记

7、查看topic的基本情况

bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic second-kafka-topic

kafka的安装与使用 _ JavaClub全栈架构师技术笔记

作者:LoongTech
来源链接:https://blog.csdn.net/loongkingwhat/article/details/122143072

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

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


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

分享给朋友:

“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...

Kafka安装

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

spring-kafka 实战

spring-kafka 实战

spring-kafka实战 1.       kafka介绍   1.1.       主要功能 根据官网的介绍,Apach...

kafka安装步骤

kafka安装步骤

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

Kafka安装之二 在CentOS 7上安装Kafka

Kafka安装之一  Zookeeper Kafka安装之二 在CentOS 7上安装Kafka 一、简介         Kafka是由Apache软件基金会开发的一个开...

windows安装kafka

windows安装kafka

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

kafka安装部署(windows)

kafka安装部署(windows)

文章目录 前言 kafka安装部署(windows) 01 zookeeper中间件 安装部署 01::01 启动zook...

ubuntu安装kafka

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

CentOs7 安装 Kafka 或 Docker 安装 Kafka

CentOs7 安装 Kafka 或 Docker 安装 Kafka

Kafka CentOs7 安装 安装zookeeper 安装 Kafka Docker 安装 安装zookeepe...

发表评论

访客

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