菜鸟先飞之Kafka安装配置和一些基本操作

本文链接：https://blog.csdn.net/wangbenguixin/article/details/108086100

本文档详细介绍了Kafka的安装过程，包括解压安装包、配置server.properties、设置环境变量，以及启动服务。接着，通过kafka-topics.sh工具创建和管理主题，包括创建、查看和删除主题，并演示了生产者和消费者的使用方法，是初学者快速上手Kafka的实用教程。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

准备好安装包：kafka_2.11-2.0.0.tgz

# 拖入本地并解压
tar -zxf kafka_2.11-0.11.0.2.tgz

# 改名
mv kafka_2.11-0.11.0.2 kafka

# 切换至kafka配置文件目录
cd /opt/soft/kafka/config

# 修改配置文件server.properties(消费者配置)
vi server.properties

# 若是集群则需要修改
broker.id=0
# 允许kafka可以删除topic
delete.topic.enable = true
# 默认监听端口单机模式可以不配置
listeners = PLAINTEXT://这边写IP地址:9092
# 修改日志临时文件存储路径可以自己指定
log.dirs = /data/kafka-logs
# 若是集群，则需要新增，单机可以不修改
zookeeper.connect = 这边写IP地址:2181

# 配置环境变量

vi /etc/profile

# kafka
export KAFKA_HOME=/opt/soft/kafka
export PATH=$PATH:$KAFKA_HOME/bin

# 使环境变量即时生效

source /etc/profile

# 后台运行kafka
kafka-server-start.sh -daemon config/server.properties

# 创建主题
kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic test

# 查看已创建的topic
kafka-topics.sh --list --zookeeper 127.0.0.1:2181

# 创建一个消息生产者
kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test

# 新开一个界面创建一个消费者
kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic test --from-beginning

# 查看topic具体描述包括 Partition Leader Replicas Isr
kafka-topics.sh --zookeeper 127.0.0.1:2181 --describe --topic test

# 删除topic
kafka-topics.sh --zookeeper 127.0.0.1:2181 --delete --topic test