Windowsでkafakをインストールする

一、インストール1、kafkaはjava環境が必要である;2、kafkaの最新バージョンにはzookeeperが内蔵されているので、zookeeperをインストールする必要はありません.インストール済みであれば直接使用してもよいし、kafkaの最新バージョンをダウンロードしてもよいので、インストールする必要はなく、対応する場所に解凍すればよい.4、binディレクトリの下にはkafkaを起動するファイル、confディレクトリの下にはkafkaの各種プロファイルが置かれています.二、簡単なdemoテストを実行し、プロファイルを変更する必要はなく、zookeeperのデフォルトポートが2181であり、生産者のデフォルトポートが9092であることを知る必要がある.1、zookeeper binwindowszookeeper-server-startを起動する.bat config\zookeeper.properties

  2、  kafka（  server        ）

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

  3、    topic，topic = demo

bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
-作成したtopic binwindowskafka-topicsを表示します.bat --list --bootstrap-server localhost:9092

  4、      producer

bin\windows\kafka-console-producer.bat--broker-list localhost:9092--topic test生産者を起動して編集ページに入り、「nihao」を送信しました.

   5、      customer

bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test–from-beginning
消費者が起動すると、以前生産者から「nihao」が送られてきた.