Kafka常用指令（详细）

Kafka常用指令（详细）

启停命令

前台启动

前台启动命令
./bin/kafka-server-start.sh config/server.properties

后台启动方式1

后台启动命令加上参数-daemon，窗口关闭之后kafka后台程序继续运行
./bin/kafka-server-start.sh -daemon config/server.properties

后台启动方式2

nohup ./bin/kafka-server-start.sh config/server.properties &

停止命令

./bin/kafka-server-stop.sh

Topic命令相关

创建Topic

./kafka-topics.sh --bootstrap-server 172.31.101.82:9092 --create --topic test_topic --partitions 2 --replication-factor 2
参数说明：
localhost:2181:zk的IP地址和端口号；
–partitions 5：创建主题分区数量为5；
== --replication-factor 2==：创建主题分区副本为2；
–topic topic_name：创建主题名称为topic_name。

查询Topic列表

列出指定服务器主题
./bin/kafka-topics.sh --bootstrap-server 192.168.1.1:9092 --list
列出kafka集群中的主题列表，192.168.1.1:9092,192.168.1.2:9092为多个kafka服务地址
./bin/kafka-topics.sh --bootstrap-server 192.168.1.1:9092,192.168.1.2:9092 --list

查询Topic详细信息

查询指定主题详细信息
./bin/kafka-topics.sh --bootstrap-server localhost:9092 --topic topic_name --describe
查询多个kafka的主题详细信息
./bin/kafka-topics.sh --bootstrap-server 192.168.1.1:9092,192.168.1.2:9092 --topic topic_name --describe
删除指定的Topic
./bin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic topic_name
修改主题的分区数，注意：分区数只能增加不能减少
./bin/kafka-topics.sh --bootstrap-server localhost:9092 --alter --topic topic_name --partitions 3

Procuder命令相关

发送消息

./bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic topic_name
./kafka-console-producer.sh --topic test_topic --broker-list 172.31.101.82:9092

#Consumer命令相关

指定主题从最新位置开始消费

消费topic_name中的最新消息
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic_name
消费topic_name中的所有消息，包含历史消息
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic topic_name
消费者组消费主题信息
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic_name --group groupId