当前位置: 首页 > news >正文

Kafka的下载安装以及使用

一、Kafka下载

下载地址:https://kafka.apache.org/downloads
在这里插入图片描述

二、Kafka安装

因为选择下载的是 .zip 文件,直接跳过安装,一步到位。
选择在任一磁盘创建空文件夹(不要使用中文路径),解压之后把文件夹内容剪切进去(本人选择 D:\env-java\路径下,即完成安装)。
linux解压命令tar -zxvf kafka_2.13-3.5.1.tgz,linux环境下指令是在\kafka_2.13-3.5.1\bin目录。
windows直接解压即可,windows环境下指令是在kafka_2.13-3.5.1\bin\windows目录。
注意:不同系统指令所在的目录不同。
执行命令当前目录D:\env-java\kafka_2.13-3.5.1

修改 kafka-server 和zookeeper配置

进入到目录:kafka_2.13-3.5.1/config/server.properties以及kafka_2.13-3.5.1/config/zookeeper.properties

  • linux系统:
broker.id=1
log.dir=/Users/imagetask/kafka-logs

在这里插入图片描述

  • windows系统:
broker.id=1
log.dirs=/env-java/kafka_2.13-3.5.1/kafka-logs

在这里插入图片描述
在这里插入图片描述
/:表示当前的根路径,即D盘。没有就会创建对应的文件夹。

三、启动Kafka服务

1、启动ZooKeeper

  • linux系统:
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
  • windows系统:
bin\windows\zookeeper-server-start.bat config\zookeeper.properties	

2、启动kafka

  • linux系统:
bin/kafka-server-start.sh config/server.properties
  • windows系统:
bin\windows\kafka-server-start.bat config\server.properties

四、Kafka的使用

1、创建主题

  • linux系统:
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
  • windows系统:
bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

2、查看Topic 列表

  • linux系统:
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
  • windows系统:
bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092

3、启动 Producer

  • linux系统:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
  • windows系统:
bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

4、启动 Consumer

  • linux系统:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
  • windows系统:
bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

5、查看Topic 相关信息(test)

  • linux系统:
bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic test
  • windows系统:
bin\windows\kafka-topics.bat --describe --bootstrap-server localhost:9092 --topic test
http://www.lryc.cn/news/123102.html

相关文章:

  • 数据库相关面试题
  • Ubuntu常用配置
  • win10MySQLServer安装过程+解决MySQL服务无法启动问题
  • 网络:CISCO、Huawei、H3C命令对照
  • 题目:2319.判断矩阵是否是 X 矩阵
  • 2023年大厂前端面试题汇总
  • 如何在Linux中查找Nginx安装目录
  • 【NLP】训练LLM的不同方式
  • MySQL 45讲笔记(1-10讲)
  • U盘数据如何保密?U盘数据加密软件合集
  • 此文详解,数据仓库管理建设的经验
  • 01 - 工作区、暂存区、版本库、远程仓库 - 以一次连贯的提交操作为例
  • cesium学习记录06-视图、场景与相机
  • flutter开发实战-MethodChannel实现flutter与原生Android双向通信
  • django使用多个数据库实现
  • Linux常见面试题,应对面试分享
  • mysql索引的数据结构(Innodb)
  • 【MySQL】Java实现JDBC编程
  • 纽扣电池寿命和功率增强器
  • bilibili倍数脚本,油猴脚本
  • 8.14 作业
  • Debian安装和使用Elasticsearch 8.9
  • 三 、CTR预估数据准备
  • netty学习分享 二
  • 聊聊web服务器NGINX
  • 【hello C++】特殊类设计
  • js实现按创建时间戳1609459200000 开始往后开始显示运行时长-demo
  • latex三线表按页面大小填充
  • 佛祖保佑,永不宕机,永无bug
  • redis分布式集群-redis+keepalived+ haproxy