Kafka環境の構築(Windows)

詳細
1、JDKのインストール
2、Zookeeper Kafkaをインストールする実行はZookeeperに依存するので、Kafkaを実行する前にZookeeper 2.1、ダウンロードインストールファイル(zookeeper-3.4.9):http://mirror.bit.edu.cn/apache/zookeeper/2.2、解凍zookeeeper-3.4.9(E:developKafkazookeeper-3.4.9に解凍)2.3、zookeeper-3.4.9confを開き、zoo_sample.cfgをzoo.cfg 2.4に名前変更、zoo.cfgプロファイルを変更する:
.5、Zookeeperを運転し、zookeeper-3.4に入る.9binディレクトリ、zkServerをダブルクリックします.cmd次の情報を印刷すると、zookeeperがインストールに成功し、2181ポートで実行されたことを示します.

 
3、Kafkaを取り付ける
 
3.1、Kafkaダウンロードアドレスhttp://kafka.apache.org/downloads.html、ダウンロードしてE:developKafkakafka_に解凍2.12-1.0.0
3.2、serverを配置する.propertiesファイル(E:developKafkakafka_2.12-1.0.0configserver.properties)では、Kafkaはデフォルトで、
9092ポートで実行し、zookeeperのデフォルトポートに接続します:2181 3.2.1、log.dirs=E:/develop/Kafka/kafka_2.12-1.0.0/tmp/kafka-logs   3.2.2、zookeeper.connect=localhost:21814、Kafkaを起動する(Kafkaサーバを起動する前に、Zookeeperインスタンスが準備されていることを確認し、実行を開始する)
4.1、サービス側を起動し、cmdコマンドウィンドウを行い、起動成功後、ウィンドウを閉じない

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

 

 
 
4.2、テーマを作成し、cmdコマンドウィンドウを行い、作成に成功した後、ウィンドウを閉じない

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kftest01 

 

 
トピックの表示

.\bin\windows\kafka-topics.bat -zookeeper localhost:2181 --list  
kftest01  

 
トピックの削除

.\bin\windows\kafka-topics.bat --delete --zookeeper localhost:2181 --topic kftest01  
Topic kf_test_01 is marked for deletion.  
Note: This will have no impact if delete.topic.enable is not set to true.  

 
 
4.3、生産者を作成し、cmdコマンドウィンドウを行い、作成に成功した後、ウィンドウを閉じない
 

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic kftest01 

 
 
 
4.4、消費者を作成し、cmdコマンドウィンドウを行い、作成に成功した後、ウィンドウを閉じない
 

.\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic kftest01

 
5、テスト