130 字
1 分钟
Kafka 跨平台安装与基础使用指南(Linux / Windows)
WARNING本文内容来源于参考教程整理,部分步骤未经实机验证,仅供参考。如有问题请以官方文档为准。
Kafka 下载地址:https://kafka.apache.org/downloads

一、安装
Linux 下载并解压:
# 解压到指定目录tar -zxvf kafka_2.13-3.5.1.tgzmv kafka_2.13-3.5.1 /opt/kafkaWindows 直接解压到合适路径即可(建议纯英文路径,如 D:\env-java\)。
NOTE
- Linux 命令在
bin/目录下执行- Windows 命令在
bin\windows\目录下执行
二、修改配置
编辑 config/server.properties 和 config/zookeeper.properties:
# Linux 配置示例broker.id=1log.dirs=/opt/kafka/logs
# Windows 配置示例broker.id=1log.dirs=D:/env-java/kafka_2.13-3.5.1/kafka-logs三、启动服务
# 启动 ZooKeeper## Linuxbin/zookeeper-server-start.sh -daemon config/zookeeper.properties## Windowsbin\windows\zookeeper-server-start.bat config\zookeeper.properties
# 启动 Kafka## Linux(后台启动,推荐)cd /opt/kafkanohup bin/kafka-server-start.sh config/server.properties 2>&1 &# 或者bin/kafka-server-start.sh -daemon config/server.properties
## Windowsbin\windows\kafka-server-start.bat config\server.properties四、常用操作
# 创建 Topic## Linuxbin/kafka-topics.sh --create --bootstrap-server localhost:9092 \ --replication-factor 1 --partitions 1 --topic test
# 查看 Topic 列表bin/kafka-topics.sh --list --bootstrap-server localhost:9092
# 查看 Topic 详情bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic test
# 删除 Topicbin/kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic test
# 启动 Producer(生产者)bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
# 启动 Consumer(消费者,从头消费)bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 \ --topic test --from-beginning
# 删除 Topic 数据(需要 delete_script.json 文件)bin/kafka-delete-records.sh --bootstrap-server localhost:9092 \ --offset-json-file delete_script.jsondelete_script.json 文件格式:
{ "partitions": [ { "topic": "test", "partition": 0, "offset": -1 } ]} 分享
如果这篇文章对你有帮助,欢迎分享给更多人!
Kafka 跨平台安装与基础使用指南(Linux / Windows)
https://blog.olinl.com/posts/centos-kafka-install/ 相关文章 智能推荐
1
CI/CD 手册:Jenkins 自动化发布全流程
服务与应用运维 详细记录如何通过 Jenkins 搭建自动化流水线,实现 Node.js 前端项目与 Spring Boot 后端项目的打包、上传及一键部署。
2
Ubuntu安装IntelliJ IDEA
服务与应用运维 详解在 Ubuntu 系统下安装 IntelliJ IDEA 的标准流程,涵盖手动解压安装、创建桌面快捷方式及全局环境变量配置。
3
PostgreSQL 备份与恢复
服务与应用运维 介绍使用 pg_dumpall 和 pg_dump 对 PostgreSQL 进行全量备份与单表备份,以及在实体机和 Docker 容器中的恢复方法。
4
PostgreSQL 外部表(FDW)跨库查询配置
服务与应用运维 使用 postgres_fdw 扩展配置 PostgreSQL 外部数据包装器,实现跨数据库实例的表查询,解决 PostgreSQL 不支持跨库查询的限制。
5
PostgreSQL 远程访问与数据目录迁移
服务与应用运维 介绍 PostgreSQL 的远程访问配置(pg_hba.conf / postgresql.conf)以及将数据目录从默认路径迁移到自定义路径的操作步骤。
