在上一篇kafka簡介的基礎之上，本篇主要介紹如何快速的運行kafka。　　

　　在進行如下配置前，首先要啟動Zookeeper。

配置單機kafka

1.進入kafka解壓目錄
2.啟動kafka

bin\windows\kafka-server-start config\server.properties

?3.創建Topic和查看機器上topic

bin\windows\kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic1 bin\windows\kafka-topics --list --zookeeper localhost:2181

?
4.發送數據

bin\windows\kafka-console-producer --broker-list localhost:9092 --topic topic1

5.開始消費數據

bin\windows\kafka-console-consumer --bootstrap-server localhost:9092 --topic topic1 --from-beginning

?

配置kafka集群

1.復制server.properties文件，并修改文件配置

broker.id=2 listeners=PLAINTEXT://:9094 log.dirs=E:\kafka_2.11-0.10.2-2\log

?2.啟動kafka

bin\windows\kafka-server-start config\server-1.properties bin\windows\kafka-server-start config\server-2.properties

?3.創建topic，然后查看集群詳細信息

bin\windows\kafka-topics --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1 --topic topic-cluster bin\windows\kafka-topics --describe --zookeeper localhost:2181 --topic topic-cluster

?

　　第一行詳細描述topic-cluster這個topic的集群信息。主要包括topic名稱、分區數目、復制因子。后面的每一行描述一個分區信息，Partition：0表示該分區編號為0；Leader：0，表示該分區的Leader的broker.id為0；replicas為所在的broker.id;該分區的ISR為0、1、2.

4.向kafka集群發送數據

bin\windows\kafka-console-producer --broker-list localhost:9092 --topic topic-cluster

?

5.開始消費數據

bin\windows\kafka-console-consumer --bootstrap-server localhost:9092 --topic topic-cluster --from-beginning

?6.測試kafka集群失敗恢復 殺死leader進程
7.查看集群信息

bin\windows\kafka-topics --describe --zookeeper localhost:2181 --topic topic-cluster

?

　　此時可以發現，該分區的Leader和ISR都發生了改變.

8.重新消費數據

bin\windows\kafka-console-consumer --bootstrap-server localhost:9092 --topic topic-cluster --from-beginning

下一篇：Kafka學習-生產者和消費者

轉載于:https://www.cnblogs.com/wxgblogs/p/6597494.html

創作挑戰賽新人創作獎勵來咯，堅持創作打卡瓜分現金大獎

總結

以上是生活随笔為你收集整理的Kafka学习-入门的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。