Windows環境でのKafkaのインストール

一、JDKのインストール
基本的にはJDKがローカルにインストールされているため、この手順を省略してcmdを直接開き、「java-version」コマンドを入力して現在のシステムのJavaバージョンを表示します.二、ZooKeeperのインストール

インストールパッケージをダウンロードします.ダウンロード先:http://zookeeper.apache.org/releases.html#download作者はapache-zookeeper-3.5.7-binをダウンロードした.tar.gzの高バージョンのzookeeperでは、apache-zookeeper-3.6.0のような2つの異なるパッケージが一般的です.tar.gzとapache-zookeeper-3.6.0-bin.tar.gzはbin付きのバイナリバージョンを使用します.そうしないと、zookeeperを起動するときに「プライマリクラスorg.apache.zookeeper.server.quorum.QuarumPeerMainが見つからないかロードできない」とエラーが発生する可能性があります.

解凍しZooKeeperのconfディレクトリに入りzoo_sample.cfgの名前をzooと変更する.cfg. 作者の目次:D:Program Filesapache-zookeeper-3.5.7-binapache-zookeeper-3.5.7-binconf

zooを開く.cfgファイルは、以下のように変更します.修正:dataDir=D:Program Filesapache-zookeeper-3.5.7-binapache-zookeeper-3.5.7-bindata追加:dataLogDir=D:Program Filesapache-zookeeper-3.5.7-binapache-zookeeper-3.5.7-binapache-zookeeper-3.5.7-binlogs追加:admin.serverPort=8888(PS:後続の起動時報8080のポート占有のため、ポート変更は8888)

.

システム変数を追加ZOKEEEPER_HOME=D:\Program Files\apache-zookeeper-3.5.7-bin\apache-zookeeper-3.5.7-bin

pathシステム変数を編集し、その後";%ZOKEEEPER_HOME%bin;"

cmdを開き、「zkServer」と入力してZookeeperを実行し、コマンドラインプロンプトを下図に示すように、ローカルZookeeperの起動に成功したことを示します. cmdウィンドウを閉じずにkafkaをインストールします.

三、kafkaのインストールと運転

インストールファイルをダウンロードします.http://kafka.apache.org/downloads.html、作者がダウンロードしたのはkafka_2.11-2.4.0.tgz.

ファイルをDディスクルートパスに解凍します.

D:kafka_へ2.11-2.4.0configディレクトリ、テキストエディタserverを開きます.properties、logを変更します.dirs=D:\kafka_2.11-2.4.0\logs

D:kafka_へ2.11-2.4.0ディレクトリ、shift+右クリック、ここでコマンドウィンドウを開き、次のコマンド

を入力します.

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

車に戻って現れる
[2020-04-09 16:55:29,122] INFO [KafkaServer id=0] started (kafka.server.KafkaServer)
起動が完了したことを示します.
PS:上記のコマンドを入力すると、以下のようなエラーが発生しました.最初は設置経路が深く、後にDディスクルート経路に変更した後、エラーが解決した.
ウィンドウを閉じないで、テストの一環に入ります.
四、kafkaをテストする

topicを作成します.D:kafka_2.11-2.4.0binwindowsパスの下でcmdウィンドウを開き、トピックtestを作成します.コマンドは次のとおりです.

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

結果は下図の通り:

PRODUCERを開きます.D:kafka_2.11-2.4.0binwindowsパスの下でcmdウィンドウを開き、次のコマンドを入力します:

kafka-console-producer.bat --broker-list localhost:9092 --topic test

CONSUMERを開きます.D:kafka_2.11-2.4.0binwindowsパスの下でcmdウィンドウを開き、次のコマンドを入力します:

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

Producerコンソールウィンドウにメッセージを入力します.メッセージが入力されると、すぐにConsumerウィンドウにProducerが送信したメッセージが表示されます.下図に示します. これでKafka実行環境の構築が完了します.