皆さん、こんにちは。この投稿では、Ubuntu20.04にApacheKafkaをインストールする方法を学びます
Apache Kafkaプラットフォームは、水平方向のスケーラビリティとフォールトトレランスを備えた分散データ伝送システムです。これは、世界中の多くの環境や、このデータ送信が必要なクラスターで使用されています。
何よりも、これはオープンソースであり、そのソースコードを調べて、サーバーに実装できます。強力なドキュメントと非常に活発なコミュニティのおかげで、ApacheKafkaは世界中で非常に高い評価を得ています。
さあ、行きましょう。
Ubuntu20.04にApacheKafkaをインストールします
インストールする前に、システムを準備するためのいくつかの準備手順を実行する必要があります。
Ubuntu20.04にJavaをインストール
Apache KafkaはJavaで作成されているため、使用できるようにインストールする必要があります。これを行うには、このコマンドを実行します
sudo apt update sudo apt install openjdk-11-jre-headless unzip
Javaの他に、unzip
をインストールしました 後で使用するためです。ただし、Javaが正常にインストールされたことを確認するには、
java --version

これで続行できます
Ubuntu20.04にApacheKafkaをダウンロード
wget
を使用しています コマンドKafkaパッケージをダウンロードできます。
wget https://dlcdn.apache.org/kafka/3.0.0/kafka_2.12-3.0.0.tgz

でファイルを解凍するフォルダを作成します
sudo mkdir /usr/local/kafka-server
/usr/local/
を選択しました フォルダとして使用できますが、任意のフォルダにすることができます。
アーカイブを解凍します
sudo tar -xzf kafka_2.12-3.0.0.tgz
そしてそれをフォルダに移動します
sudo mv kafka_2.12-3.0.0.0/* /usr/local/kafka-server
次に、zookeeper
のサービスファイルを作成する必要があります およびkafka
開始、停止、および実行ステータスを確認できるようにします。
zookeeper
の場合
sudo nano /etc/systemd/system/zookeeper.service
そして、以下を追加します
[Unit] Description=Apache Zookeeper Server Requires=network.target remote-fs.target After=network.target remote-fs.target [Service] Type=simple ExecStart=/usr/local/kafka-server/bin/zookeeper-server-start.sh /usr/local/kafka-server/config/zookeeper.properties ExecStop=/usr/local/kafka-server/bin/zookeeper-server-stop.sh Restart=on-abnormal [Install] WantedBy=multi-user.target

変更を保存してエディタを閉じます。
今Kafka
1つ
sudo nano /etc/systemd/system/kafka.service
このコンテンツを追加
[Unit] Description=Apache Kafka Server Documentation=http://kafka.apache.org/documentation.html Requires=zookeeper.service After=zookeeper.service [Service] Type=simple Environment="JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64" ExecStart=/usr/local/kafka-server/bin/kafka-server-start.sh /usr/local/kafka-server/config/server.properties ExecStop=/usr/local/kafka-server/bin/kafka-server-stop.sh Restart=on-abnormal [Install] WantedBy=multi-user.target

もう一度、変更を保存してエディタを閉じます。
新しいサービスに変更を適用するには、
を実行しますsudo systemctl daemon-reload
両方のサービスを有効にして開始します。まず、zookeeper
1つ
sudo systemctl enable --now zookeeper.service Created symlink /etc/systemd/system/multi-user.target.wants/zookeeper.service → /etc/systemd/system/zookeeper.service
そして、Kafka
1つ
sudo systemctl enable --now kafka.service Created symlink /etc/systemd/system/multi-user.target.wants/kafka.service → /etc/systemd/system/kafka.service
次に、両方のサービスステータスを確認します
sudo systemctl status kafka

そして
sudo systemctl status zookeeper

ご覧のとおり、サービスは正常に機能しており、これまでのところすべてが順調に進んでいます。
CMAKのインストール–ApacheKafkaのクラスターマネージャー
この手順はオプションですが、ApacheKafkaを起動して実行すると便利です。
だから、git
の助けを借りて アプリケーションリポジトリのクローンを作成します。
git clone https://github.com/yahoo/CMAK.git
git
がない場合 インストールすると、実行できます
sudo apt install git
次に、アプリケーション構成ファイルを変更する必要があります。
sudo nano CMAK/conf/application.conf

その中で、cmak.zkhosts
の値を探します それに別の値を割り当てます。
cmak.zkhosts="localhost:2181"
下の画像を参照して、プロセスが正しく行われていることを確認してください。変更を保存してエディタを閉じます。
次に、CMAK
にアクセスします フォルダ。
cd CMAK
そして、ZIPファイルを生成するように構成します。
./sbt clean dist

target/universal
にアクセスします ディレクトリ。
cd target/universal
そしてファイルを解凍します
sudo unzip cmak-3.0.0.5.zip
生成されたフォルダにアクセスします
cd cmak-3.0.0.5
そして、アプリケーションを実行します
sudo bin/cmak
次に、Webブラウザーを開いて、http://your-server:9000
にアクセスします。 次のように表示されます

だから、プロセスは成功しました楽しんでください。
この投稿では、Ubuntu20.04にApacheKafkaをインストールする方法を段階的に学びました。これで、このすばらしいツールを使い始めることができます。