このチュートリアルでは、Ubuntu 20.04LTSにApacheKafkaをインストールする方法を紹介します。知らなかった人のために、Kafkaは最も人気のあるオープンソースソフトウェアであり、ストリーミングデータを保存、読み取り、分析するためのフレームワーク。KafkaはもともとLinkedInによって開発され、2011年の初めにApacheSoftwareFoundationの下でオープンソース化される予定です。
この記事は、少なくともLinuxの基本的な知識があり、シェルの使用方法を知っていること、そして最も重要なこととして、サイトを独自のVPSでホストしていることを前提としています。インストールは非常に簡単で、ルートアカウントで実行されていますが、そうでない場合は、'sudo
を追加する必要があります。 ‘ルート権限を取得するコマンドに。 Ubuntu 20.04(Focal Fossa)にApacheKafkaを段階的にインストールする方法を紹介します。 Ubuntu 18.04、16.04、およびLinuxMintなどの他のDebianベースのディストリビューションでも同じ手順に従うことができます。
前提条件
- 次のオペレーティングシステムのいずれかを実行しているサーバー:Ubuntu 20.04、18.04、16.04、およびLinuxMintなどの他のDebianベースのディストリビューション。
- 潜在的な問題を防ぐために、OSの新規インストールを使用することをお勧めします。
non-root sudo user
またはroot user
へのアクセス 。non-root sudo user
として行動することをお勧めします ただし、ルートとして機能するときに注意しないと、システムに害を及ぼす可能性があるためです。
Ubuntu 20.04 LTSFocalFossaにApacheKafkaをインストールします
手順1.まず、次のapt
を実行して、すべてのシステムパッケージが最新であることを確認します。 ターミナルのコマンド。
sudo apt update sudo apt upgrade
ステップ2.Javaをインストールします。
Apache Kafkaでは、サーバーにJavaがインストールされている必要があります。次のコマンドを実行して、UbuntuシステムにOpenJDKをインストールします。
sudo apt install openjdk-11-jdk
次のコマンドを実行して、Javaのバージョンを確認します。
$ java -version java version "1.8.0_251" Java(TM) SE Runtime Environment (build 1.8.0_251-b07) Java HotSpot(TM) 64-Bit Server VM (build 25.251-b07, mixed mode)>
ステップ3.Ubuntu20.04にApacheKafkaをインストールします。
これで、公式Webページから最新バージョンのKafkaをダウンロードします:
wget https://downloads.apache.org/kafka/2.6.0/kafka_2.13-2.6.0.tgz
次に、アーカイブファイルのtarを解除して、別の場所に移動します:
sudo tar xzf kafka_2.13-2.6.0.tgz sudo mv kafka_2.13-2.6.0 /opt/kafka
ステップ4.ZookeeperとKafkaSystemdユニットファイルを作成します。
systemd
を作成します 動物園飼育員サービスのユニットファイル:
sudo nano /etc/systemd/system/zookeeper.service
次の行を追加します:
[Unit] Description=Apache Zookeeper service Documentation=http://zookeeper.apache.org Requires=network.target remote-fs.target After=network.target remote-fs.target [Service] Type=simple ExecStart=/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties ExecStop=/opt/kafka/bin/zookeeper-server-stop.sh Restart=on-abnormal [Install] WantedBy=multi-user.target
次に、systemd
を作成します Kafkaサービスのユニットファイル:
sudo nano /etc/systemd/system/kafka.service
次の行を追加します:
[Unit] Description=Apache Kafka Service Documentation=http://kafka.apache.org/documentation.html Requires=zookeeper.service [Service] Type=simple Environment="JAVA_HOME=/opt/jdk/jdk1.8.0_251" ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties ExecStop=/opt/kafka/bin/kafka-server-stop.sh [Install] WantedBy=multi-user.target
デーモンをリロードして有効にします:
sudo systemctl daemon-reload sudo systemctl enable --now zookeeper sudo systemctl enable --now kafka
ステップ5.Kafkaでトピックを作成します。
次に、単一のレプリケーションファクタとパーティションを使用して「idroot」という名前のトピックを作成します。
cd /opt/kafka sudo bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-f
作成したトピックのメッセージを送信するには:
sudo bin/kafka-console-producer.sh --broker-list localhost:9092 --topic idoot
入力するメッセージの入力を求めるプロンプトが表示されます:
> Hi > How are you?
以下のコマンドを使用すると、メッセージのリストを表示できます:
sudo bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic idroot --from-beginning
ステップ6.リモートマシンからKafkaを接続するには。
接続、トピックの作成、およびリモートサーバーからのメッセージの送信を行うには、次の手順に従ってください。
cd /opt/kafka/config
次にserver.properties
を探します 構成を変更します:
sudo nano server.properties
listeners=PLAINTEXT://:9092 advertised.listeners=PLAINTEXT://<HOST IP>:9092
おめでとうございます!ApacheKafkaが正常にインストールされました。Ubuntu20.04LTSFocalFossaシステムにApacheKafkaをインストールするためにこのチュートリアルを使用していただき、ありがとうございます。追加のヘルプや役立つ情報については、公式を確認することをお勧めします。 ApacheKafkaのWebサイト。