kafka常用命令和内外网访问配置_kafka 127.0.0.1访问

Kafka常用命令

#启动kafka
kafka-server-start.sh -daemon config/server.properties
#关闭kafka
kafka-server-stop.sh stop
#查看当前服务器中的所有topic
kafka-topics.sh --zookeeper 127.0.0.1:2981 --list
#创建topic  replication-factor 定义副本数 partitions定义分区数
kafka-topics.sh --zookeeper 127.0.0.1:2981 --create --replication-factor 1 --partitions 1 --topic first
#删除topic
kafka-topics.sh --zookeeper 127.0.0.1:2981 --delete --topic first
#发送消息
kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic first
#消费消息
kafka-console-consumer.sh --zookeeper 127.0.0.1:2981 --topic first

#查看某个Topic的详情
kafka-topics.sh --zoo
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16