# Kafka ## 注意事项 一定要先启动Zookeeper再启动Kafka，顺序不可以改变。 关闭的话需要先关闭Kafka，在关闭Zookeeper。其次启动命令建议加上-daemon，后台运行。 ## 常用命令 ### 启动关闭相关 ``` 启动zk： ./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties 启动Kafka： ./bin/kafka-server-start.sh -daemon config/server.properties 停止Kafka： ./bin/kafka-server-stop.sh 停止zk： ./bin/zookeeper-server-stop.sh ``` ### topic相关 ``` 创建名为test的topic： ./bin/kafka-topics.sh -zookeeper localhost:2181 --create --partitions 5 --replication-factor 1 --topic test -partitions：分区数 -replication-factor：副本数 查询topic列表： bin/kafka-topics.sh --list --zookeeper localhost:2181 删除名为test的topic： bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic test 查询topic信息： bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test 如果未指定topic，则输出所有topic的信息 增加partition数量（不允许减少）： ./bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --topic test --partitions 10 ``` ### 消息相关 ``` 生产者发送消息： bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 消费者查询消息： bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning --group t1 –from-beginning：表示从头开始接收数据 –group：指定消费者组 查询名为test的Topic消息： bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test --time -1 –time-1 表示要获取指定 topic 所有分区当前的最大位移（历史总消息数），–time-2 表示获取当前最早位移（被消费的消息数），两个命令的输出结果相减便可得到所有分区当前的消息总数。 第一个数字表示分区，第二个数字表示偏移量。 ```