Windowsインストール運転Kafka

一、JAVA JDK 1をインストールする.インストールパッケージ2をダウンロードします.jdk環境変数構成
二、Zookeeperのインストール注意:zookeeperウィンドウを閉じない
三、Kafka 1を取り付ける.インストールパッケージのダウンロードhttp://kafka.apache.org/downloads
2.解凍してKafkaディレクトリに入り、筆者:E:kafka_2.13-2.6.0 3.configディレクトリに入ってファイルserverを見つけます.properties、編集を開きます.Kafkaデフォルトポート:9092、zeekeeperデフォルトポート:2181

log.dirs=E:\kafka_2.13-2.6.0\kafka-logs
zookeeper.connect=localhost:2181

4.KafkaインストールディレクトリE:kafka_へ2.13-2.6.0、Shift+右ボタンを押して、「コマンドウィンドウを開く」オプションを選択します.コマンドラインを開き、入力

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

注:ウィンドウを閉じないでKafkaを起動zookeeperが実行されていることを確認するには
四、テスト
1.テーマを作成し、KafkaのインストールディレクトリE:kafka_に入る2.13-2.6.0、Shift+右ボタンを押して、「コマンドウィンドウを開く」オプションを選択して、コマンドラインを開き、入力:

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

注:ウィンドウを閉じない
トピックの表示

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

2.生産者を作成し、KafkaのインストールディレクトリE:kafka_に入る2.13-2.6.0、Shift+右ボタンを押して、「コマンドウィンドウを開く」オプションを選択して、コマンドラインを開き、入力:

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

注:ウィンドウを閉じないでください
3.消費者を作成し、KafkaのインストールディレクトリE:kafka_に入る2.13-2.6.0、Shift+右ボタンを押して、「コマンドウィンドウを開く」オプションを選択して、コマンドラインを開き、入力:

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test2 --from-beginning