· 启动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
