このチュートリアルでは、CentOS8にApacheKafkaをインストールする方法を示します。知らなかった方のために、ApacheKafkaは大量のデータを処理するように設計された分散メッセージエージェントです。 ActiveMQやRabbitMQなどの従来のエージェントとは異なり、Kafkaは1つ以上のサーバーの集まりとして機能し、拡張性が高く、分散型であるため、フォールトトレランスが組み込まれていると同時に、スループットを向上させます。カウンターパート。
この記事は、少なくともLinuxの基本的な知識があり、シェルの使用方法を知っていること、そして最も重要なこととして、サイトを独自のVPSでホストしていることを前提としています。インストールは非常に簡単で、ルートアカウントで実行されていますが、そうでない場合は、'sudoを追加する必要があります。 ルート権限を取得するコマンドに‘。 CentOS8サーバーへのApacheKafkaのインストールを段階的に説明します。
前提条件
- 次のオペレーティングシステムのいずれかを実行しているサーバー：CentOS8。
- 潜在的な問題を防ぐために、OSの新規インストールを使用することをお勧めします。
non-root sudo userまたはroot userへのアクセス 。non-root sudo userとして行動することをお勧めします ただし、ルートとして機能するときに注意しないと、システムに害を及ぼす可能性があるためです。
CentOS8にApacheKafkaをインストールする
ステップ1.まず、システムが最新であることを確認することから始めましょう。
sudo dnf update
ステップ2.Javaをインストールします。
Apache Kafkaでは、サーバーにJavaがインストールされている必要があります。次のコマンドを実行してOpenJDKをマシンにインストールできます。
sudo dnf install java-11-openjdk
次のコマンドを実行して、Javaのバージョンを確認します。
java -version
ステップ3.CentOS8にApacheKafkaをインストールします。
まず、ApacheWebサイトからKafkaをダウンロードして抽出します。wgetを使用できます。 Kafkaをダウンロードするには：
wget http://www-us.apache.org/dist/kafka/2.4.0/kafka_2.13-2.4.0.tgz
次に、アーカイブファイルを抽出します：
tar xzf kafka_2.13-2.4.0.tgz mv kafka_2.13-2.4.0 /usr/local/kafka
ステップ4.KafkaSystemdユニットファイルをセットアップします。
まず、systemdを作成します 以下のコマンドを使用したZookeeperのユニットファイル：
nano /etc/systemd/system/zookeeper.service
以下のコンテンツを追加：
[Unit] Description=Apache Zookeeper server Documentation=http://zookeeper.apache.org Requires=network.target remote-fs.target After=network.target remote-fs.target [Service] Type=simple ExecStart=/usr/local/kafka/bin/zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties ExecStop=/usr/local/kafka/bin/zookeeper-server-stop.sh Restart=on-abnormal [Install] WantedBy=multi-user.target
次に、Kafka systemdを作成します 次のコマンドを使用したユニットファイル：
nano /etc/systemd/system/kafka.service
以下のコンテンツを追加します：
[Unit] Description=Apache Kafka Server Documentation=http://kafka.apache.org/documentation.html Requires=zookeeper.service [Service] Type=simple Environment="JAVA_HOME=/usr/lib/jvm/jre-11-openjdk" ExecStart=/usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties ExecStop=/usr/local/kafka/bin/kafka-server-stop.sh [Install] WantedBy=multi-user.target
systemdをリロードします 変更を適用するデーモン：
systemctl daemon-reload
ステップ5.Kafkaサーバーを起動します。
KafkaにはZooKeeperが必要だったので、まず、システムでZooKeeperサーバーを起動します：
sudo systemctl start zookeeper
次に、Kafkaサーバーを起動し、実行ステータスを表示します：
sudo systemctl start kafka sudo systemctl status kafka
ステップ6.ApacheKafkaでトピックを作成します。
「プロデューサー」は、Kafkaにデータを入力するプロセスです。Kafkaには、ファイルまたは標準から入力を受け取るコマンドラインクライアントが付属しています。入力して、メッセージとしてKafkaクラスターに送信します：
cd /usr/local/kafka bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testTopic Created topic NewTopic.
上記と同じコマンドを実行して複数のトピックを作成できます。その後、以下のコマンドを実行して、Kafkaで作成されたトピックを確認できます。
bin/kafka-topics.sh --list --zookeeper localhost:2181 NewTopic KafkaonCentOS8 KafkaonCentOS8
ステップ7.ApacheKafkaのプロデューサーとコンシューマー。
プロデューサーを実行してから、コンソールにいくつかのメッセージを入力してサーバーに送信しましょう：
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic NewTopic >Welcome to kafka >This is my new topic >
Kafkaには、Kafkaクラスターからデータを読み取り、メッセージを標準出力に表示するコマンドラインコンシューマーもあります：
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic NewTopic --from-beginning Welcome to kafka This is my new topic
おめでとうございます！ApacheKafkaが正常にインストールされました。CentOS8システムにApacheKafkaをインストールするためにこのチュートリアルを使用していただき、ありがとうございます。追加のヘルプや役立つ情報については、ApacheKafkaの公式Webサイトを確認することをお勧めします。 。