このチュートリアルでは、Ubuntu 16.04LTSにApacheKafkaをインストールする方法を示します。知らなかった方のために、ApacheKafkaは巨大な処理を行うように設計された分散メッセージエージェントです。 ActiveMQやRabbitMQなどの従来のエージェントとは異なり、Kafkaは1つ以上のサーバーの集まりとして機能し、拡張性が高く、分散型であるため、フォールトトレランスが組み込まれていると同時に、その対応物。
この記事は、少なくともLinuxの基本的な知識があり、シェルの使用方法を知っていること、そして最も重要なこととして、サイトを独自のVPSでホストしていることを前提としています。インストールは非常に簡単で、ルートアカウントで実行されていますが、そうでない場合は、'sudo
を追加する必要があります。 ‘ルート権限を取得するコマンドに。 Ubuntu 16.04XenialXerusサーバーにApacheKafkaを段階的にインストールする方法を説明します。
Ubuntu16.04LTSにApacheKafkaをインストールします
手順1.まず、次のapt-get
を実行して、すべてのシステムパッケージが最新であることを確認します。 ターミナルのコマンド。
sudo apt-get update sudo apt-get upgrade
ステップ2.Javaをインストールします。
KafkaはJavaで記述されているため、システムにJavaをインストールする必要があります:
add-apt-repository -y ppa:webupd8team/java
終了したら、次のコマンドを実行してJavaをインストールします。
apt-get update apt-get install oracle-java8-installer
ステップ3.Zookeeperをインストールします。
Apache Kafkaはクラスター管理をZookeeperに依存しているため、Kafkaを開始する前に、Zookeeperを開始する必要があります。
apt-get install zookeeperd
インストールが完了すると、ZooKeeperはデーモンとして自動的に開始されます。デフォルトでは、ポート2181でリッスンします:
netstat -ant | grep :2181
ステップ4.Kafkaサーバーをインストールします。
まず、ApacheWebサイトからKafkaをダウンロードして抽出します。wget
を使用できます。 Kafkaをダウンロードするには:
mkdir /opt/Kafka cd /opt/Kafka wget http://ftp.jaist.ac.jp/pub/apache/kafka/0.10.0.0/kafka_2.11-0.10.0.0.tgz
/opt/Kafka
のtarコマンドを使用してダウンロードしたアーカイブを抽出します :
tar -xvf kafka_2.11-0.10.0.0.tgz -C /opt/Kafka/
Kafkaサーバーの構成:
sudo /opt/Kafka/kafka_2.11-0.10.0.0/bin/kafka-server-start.sh /opt/Kafka/kafka_2.11-0.10.0.0/config/server.properties
nohup
を使用できます バックグラウンドプロセスとしてKafkaサーバーを起動するスクリプトを使用:
sudo nohup /opt/Kafka/kafka_2.11-0.10.0.0/bin/kafka-server-start.sh /opt/Kafka/kafka_2.11-0.10.0.0/config/server.properties /tmp/kafka.log 2>&1 &
次に、Kafkaサーバーが正しく動作していることを確認します。
sudo /opt/Kafka/kafka_2.11-0.10.0.0/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testing>
次の出力が表示されます:
Created topic "testing".
次に、ZookeeperにApacheKafkaで利用可能なトピックをリストするように依頼します。
sudo /opt/Kafka/kafka_2.11-0.10.0.0/bin/kafka-topics.sh --list --zookeeper localhost:2181
次の出力が表示されます:
testing
次に、次のプロデューサーコマンドを使用して、テストと呼ばれるApacheKafkaトピックにサンプルメッセージを公開します。
sudo /opt/Kafka/kafka_2.11-0.10.0.0/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testing
最後に、consumerコマンドを使用して、次のコマンドを実行することにより、テストと呼ばれるApacheKafkaトピックのメッセージを確認します。
sudo /opt/Kafka/kafka_2.11-0.10.0.0/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic testing --from-beginning
次の出力が表示されます:
Hi how are you? Where are you?
これで、ApacheZookeeperで有効なApacheKafkaがセットアップされていることを確認できました。
おめでとうございます!ApacheKafkaが正常にインストールされました。Ubuntu16.04システムにApacheKafkaをインストールするためにこのチュートリアルを使用していただき、ありがとうございます。追加のヘルプや役立つ情報については、公式のApacheKafkaを確認することをお勧めします。ウェブサイト。