Kafka 基础命令
- Kafka 部署路径说明
- # 程序部署路径：
/opt/kafka
# 配置文件路径：
/opt/kafka/config
# 启动脚本目录
/opt/kafka/bin
# 数据持久化目录
/opt/kafka/kafka-logs - Kafka 启停命令说明
- #切换路径至：
cd /opt/kafka/bin
#前台启动命令
sh kafka-server-start.sh config/server.properties
#后台启动命令
sh kafka-server-start.sh -daemon config/server.properties
#停止命令
sh kafka-server-stop.sh - Kafka Topic 相关命令说明
- #创建Topic 命令，我们一般创建分区12 复制 3 ，--zookeeper 为zookeeper节点 ip端口
sh kafka-topics.sh --zookeeper server13:2181 --create --partitions 12 --replication-factor 3 --topic TESTQ
#列出所有的topic
sh kafka-topics.sh --zookeeper server13:2181 --list
#查看某个topic详情
sh kafka-topics.sh --zookeeper server13:2181 --describe --topic TESTWLSQ - Kafka 消息相关命令
- # 生产者发送消息
sh kafka-console-producer.sh --broker-list server13:9096 --topic TESTWLSQ
# 消费者接收消息
# 从头开始消费消息
sh kafka-console-consumer.sh --bootstrap-server server13:9096 --from-beginning --topic TESTWLSQ
# 从尾开始消费消息
sh kafka-console-consumer.sh --bootstrap-server server13:9096 --topic TESTWLSQ
# 指定组名消费(应用程序已堆积，需要快速消费掉之前堆积的消息时）
sh kafka-console-consumer.sh --bootstrap-server server13:9096 --from-beginning --topic TESTWLSQ --group t1 --property print.value=true - Kakfa 消费者组相关命令
# 查看消费者列表
sh kafka-consumer-groups.sh --bootstrap-server server13:9096 --list
# 查看消费者队列深度
sh kafka-consumer-groups.sh --bootstrap-server server13:9096 --describe --group relationCompute