【Apache Kafka】Kafka學習筆記

 

0x00 基本信息

一、Kafka架構圖

二、環境信息

• 服務器IP：xx.xx.xx.xx
• 操做系統：CentOS7.2_x64
• Kafka版本：kafka_2.12-1.1.0
• Zookeeper版本：zookeeper-3.4.12

0x01 讓Kafka運行起來

一、先啓動Zookeeper

$ cd /opt/kafka/zookeeper-3.4.12/bin
$ zkServer.sh start

確認zookeeper是否成功啓動：

$ netstat -an | grep 2181
tcp6 0 0 :::2181 :::* LISTEN

返回以上結果說明成功啓動，接下來就能夠啓動kafka服務並使用具體的kafka命令來進行相應操做了。

二、啓動kafka服務

$ cd /opt/kafka/kafka_2.12-1.1.0/bin
$ ./kafka-server-start.sh -daemon /opt/kafka/kafka_2.12-1.1.0/config/server.properties

確認kafka服務是否正常啓動：

$ ps -ef | grep kafka

返回以上結果說明成功啓動。

0x02 Kafka指令

利用kafka指令進行具體的操做。

一、查看當前已有的topic

$ cd /opt/kafka/kafka_2.12-1.1.0/bin
$ ./kafka-topics.sh --list --zookeeper localhost:2181

二、建立topic test-topic的生產者

$ ./kafka-console-producer.sh --broker-list PLAINTEXT://xx.xx.xx.xx:9092 --topic test-topic

三、建立topic test-topic的消費者

./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test-topic --from-beginning

這樣，在2中建立的生產者命令行中發送的消息，3中建立的消費者就能夠及時接收到。
注意：上面截圖中提示舊的消費者建立方式將會廢棄，建議使用bootstrap-server這種新的方式，以下：

./kafka-console-consumer.sh --bootstrap-server xx.xx.xx.xx:9092 --topic test-topic --from-beginning

四、建立新topic

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic my-test-topic

五、查看某個topic的詳細信息

./kafka-topics.sh --describe --zookeeper localhost:2181 --topic test-topic

六、修改已有topic

# 已經存在topic my-test-topic，且該topic以前分區數爲1，如今咱們將該topic的分區數修改爲2
./kafka-topics.sh --zookeeper localhost:2181 --alter --topic my-test-topic --partitions 2

七、刪除某個topic

./kafka-topics.sh --zookeeper localhost:2181 --delete --topic my-test-topic

 本文到此結束。