1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
# 启动命令
$> bin/kafka-server-start.sh <$config_file_path>
## demo: 启动命令
$> bin/kafka-server-start.sh config/server.properties

# 终止命令
$> bin/kafka-server-stop.sh <$config_file_path>
## demo: 终止命令
$> bin/kafka-server-stop.sh config/server.properties

# 创建主题
$> bin/kafka-topics.sh --create --zookeeper <$ip>:<$port> --replication-factor <$num> --partitions <$num> --topic <$topicNname>
## demo: 创建主题
$> bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic Hello-Kafka

# 修改主题分区数
$> bin/kafka-topics.sh --zookeeper <$ip>:<$port> --alter --topic <$topicName> --partitions <$num>
## demo: 修改主题分区数
$> bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic Hello-Kafka --partitions 8

# 删除主题
# 注意:如果 delete.topic.enable 未设置为 true,则此操作不会产生任何影响
$> bin/kafka-topics.sh --zookeeper <$ip>:<$port> --delete --topic <$topicName> 
## demo: 删除主题
$> bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic Hello-Kafka

# 查看主题列表
$> bin/kafka-topics.sh --list --zookeeper <$ip>:<$port>
## demo: 查看主题列表
$> bin/kafka-topics.sh --list --zookeeper localhost:2181

# 启动命令行生产者,需要发送的消息在命令行输入
$> bin/kafka-console-producer.sh --broker-list <$ip>:<$port> --topic <$topicName>
## demo: 生产消息
$> bin/kafka-console-producer.sh --broker-list localhost:9092 --topic Hello-Kafka

# 启动命令行消费者
$> bin/kafka-console-consumer.sh --zookeeper <$ip>:<$port> --bootstrap-server <$ip>:<$port> --topic <$topicName> --from-beginning
# 注意:新版本无需增加 --zookeeper <$ip>:<$port>,增加后会爆 zookeeper is not a recognized option
$> bin/kafka-console-consumer.sh --bootstrap-server <$ip>:<$port> --topic <$topicName> --from-beginning
## demo: 消费消息
$> bin/kafka-console-consumer.sh --zookeeper localhost:2181 --bootstrap-server localhost:9092 --topic Hello-Kafka --from-beginning