[TOC] # kafka常用操作及API ## 1 Kafka常用操作命令 1) 查看當前服務器中的所有topic ~~~ bin/kafka-topics.sh --list --zookeeper zk01:2181 ~~~ 2) 創建topic ~~~ bin/kafka-topics.sh --create --zookeeper zk01:2181 --replication-factor 1 --partitions 1 --topic test ~~~ 3) 刪除topic ~~~ sh bin/kafka-topics.sh --delete --zookeeper zk01:2181 --topic test ~~~ > 需要server.properties中設置delete.topic.enable=true否則只是標記刪除或者直接重啟。 4) 通過shell命令發送消息 ~~~ kafka-console-producer.sh --broker-list kafka01:9092 --topic itheima ~~~ 5) 通過shell消費消息 ~~~ sh bin/kafka-console-consumer.sh --zookeeper zk01:2181 --from-beginning --topic test1 ~~~ 6) 查看消費位置 ~~~ sh kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper zk01:2181 --group testGroup ~~~ 7) 查看某個Topic的詳情 ~~~ sh kafka-topics.sh --topic test --describe --zookeeper zk01:2181 ~~~ 8) 對分區數進行修改 ~~~ kafka-topics.sh --zookeeper zk01 --alter --partitions 15 --topic utopic ~~~ ## 2、Kafka生產者Java API  ## 3、Kafka消費者Java API