0
点赞
收藏
分享

微信扫一扫

Kafka3.0.0单机安装及简单使用

木匠0819 2022-03-12 阅读 55
kafka

1.下载Kafka3.0.0
下载地址:Kafka下载
我下载的是kafka_2.12-3.0.0.tgz 版本的,本文也是基于此版本。

2.安装
下载完成后上传到linux后,进行解压,命令:

tar -zxf kafka_2.12-3.0.0.tgz

然后进入解压后的目录,创建logs文件夹

cd kafka_2.12-3.0.0/
mkdir logs

之后进入config目录,修改 server.properties 的如下内容:

listeners=PLAINTEXT://localhost:9092
log.dirs=/software/kafka_2.12-3.0.0/logs

3.启动Kafka
先启动zookeeper
以守护进程启动zookeeper:

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

接着启动kafka:

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

在logs目录下查看server.log,如果提示started,则表示启动成功,不然就根据错误的原因重新修改。
在这里插入图片描述
4.简单测试
创建topic:

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

查看topic:

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

删除topic:

bin/kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic name

生产消息:

bin/kafka-console-producer.sh --topic test1 --bootstrap-server localhost:9092

在这里插入图片描述

消费消息:

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

在这里插入图片描述

举报

相关推荐

0 条评论