このチュートリアルでは、Debian9にApacheKafkaをインストールする方法を示します。知らない人のために、ApacheKafkaは大量のデータを処理するように設計された分散メッセージエージェントです。 ActiveMQやRabbitMQなどの従来のエージェントとは異なり、Kafkaは1つ以上のサーバーの集まりとして機能するため、拡張性が高く、分散型であるため、フォールトトレランスが組み込まれていると同時に、対応するものと比較してスループットが向上します。 。
この記事は、少なくともLinuxの基本的な知識があり、シェルの使用方法を知っていること、そして最も重要なこととして、サイトを独自のVPSでホストしていることを前提としています。インストールは非常に簡単で、ルートアカウントで実行されていますが、そうでない場合は、'sudoを追加する必要があります。 ルート権限を取得するコマンドに‘。 Debian 9（Stretch）サーバーへのApacheKafkaのインストールを段階的に説明します。
前提条件
- 次のオペレーティングシステムのいずれかを実行しているサーバー：Debian 9（Stretch）。
- 潜在的な問題を防ぐために、OSの新規インストールを使用することをお勧めします。
- サーバーへのSSHアクセス（またはデスクトップを使用している場合はターミナルを開く）
non-root sudo userまたはroot userへのアクセス 。non-root sudo userとして行動することをお勧めします ただし、ルートとして機能するときに注意しないと、システムに害を及ぼす可能性があるためです。
Debian9StretchにApacheKafkaをインストールする
ステップ1.ソフトウェアをインストールする前に、次のapt-getを実行して、システムが最新であることを確認することが重要です。 ターミナルのコマンド：
apt-get update apt-get upgrade
ステップ2.Javaをインストールします。
KafkaはJavaで記述されているため、システムにJavaをインストールする必要があります：
apt-get install default-jdk
ステップ4.Kafkaサーバーをインストールします。
まず、ApacheWebサイトからKafkaをダウンロードして抽出します。wgetを使用できます。 Kafkaをダウンロードするには：
wget http://www-us.apache.org/dist/kafka/1.0.1/kafka_2.12-1.0.1.tgz
tarを使用してダウンロードしたアーカイブを抽出します / opt / Kafkaのコマンド：
tar xzf kafka_2.12-1.0.1.tgz mv kafka_2.12-1.0.1 /usr/local/kafka
KafkaはZooKeeperを使用しているため、まず、システムでZooKeeperサーバーを起動します。
cd /usr/local/kafka bin/zookeeper-server-start.sh config/zookeeper.properties
単一のパーティションと1つのレプリカのみを使用して「NewTopic」という名前のトピックを作成しましょう：
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic NewTopic Created topic "NewTopic".
これで、list topicコマンドを実行して、Kafkaで作成されたトピックを表示できます。
bin/kafka-topics.sh --list --zookeeper localhost:2181 NewTopic
Kafkaには、Kafkaクラスターからデータを読み取り、メッセージを標準出力に表示するためのコマンドラインコンシューマーもあります。
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic NewTopic --from-beginning Welcome to kafka This is my New topic
おめでとうございます！ApacheKafkaが正常にインストールされました。Debian9StretchシステムにInstallKotlinコンパイラをインストールするためにこのチュートリアルを使用していただきありがとうございます。追加のヘルプや役立つ情報については、公式のApacheKafkawebを確認することをお勧めします。サイト。