· 启动kafka

nohup kafka-server-start.sh /export/server/kafka_2.12-2.4.1/config/server.properties &

· 查看当前主题

# 查看目前kafka的主题
kafka-topics.sh --list --bootstrap-server node1:9092

# 查看某主题详情
kafka-topics.sh --describe --bootstrap-server node1:9092 --topic test

· 创建主题

# 默认一个分区和一个副本，不一定在执行命令的节点上创建
kafka-topics.sh --create --bootstrap-server node1:9092 --topic test

# 创建主题，设定4个分区，3个副本
kafka-topics.sh --create --bootstrap-server node1.itcast.cn:9092 --topic test --partitions 4 --replication-factor 3

· 删除主题

# 只是在zk中的/admin/delete_topics路径下创建一个待删除主题的同名节点，以此标记该主题的待删除状态
kafka-topics.sh --delete --topic test --zookeeper master:9092/kafka

# 彻底删除kafka主题
https://blog.csdn.net/Vector97/article/details/100565888

· 启动生产者

kafka-console-producer.sh --broker-list node1:9092 --topic test

· 启动消费者

kafka-console-consumer.sh --bootstrap-server node1:9092 --topic test

· 修改主题分区

# 修改分区数量
kafka-topics.sh --alter  --bootstrap-server node1:9092 --topic test --partitions 3

· 生产消息基准测试

bin/kafka-producer-perf-test.sh --topic test --num-records 5000000 --throughput -1 --record-size 1000 --producer-props bootstrap.servers=node1.itcast.cn:9092 acks=1

· 消费消息基准测试

bin/kafka-consumer-perf-test.sh --broker-list node1.itcast.cn:9092,node2.itcast.cn:9092,node3.itcast.cn:9092 --topic benchmark --fetch-size 1048576 --messages 5000000