3.3. Kafka のインストール
Red Hat Enterprise Linux に Kafka をインストールするには、Streams for Apache Kafka の ZIP ファイルを使用します。Kafka は、シングルノード環境または複数ノード環境にインストールできます。この手順では、単一の Kafka ブローカーと ZooKeeper インスタンスが単一のホスト (ノード) にインストールされます。
Streams for Apache Kafka のインストールファイルには、Kafka Connect、Kafka MirrorMaker 2、Kafka Bridge などの他の Kafka コンポーネントを実行するためのバイナリーが含まれています。単一ノード環境では、Kafka をインストールした同じホストからこれらのコンポーネントを実行できます。ただし、インストールファイルを追加し、他の Kafka コンポーネントは別のホストで実行することを推奨します。
Apache ZooKeeper は、高信頼性の分散調整のためのクラスター調整サービスを提供します。Kafka は ZooKeeper を使用して設定データを保存し、クラスターの調整を行います。Kafka を実行する前に、ZooKeeper クラスターを準備する必要があります。
マルチノード環境を使用している場合は、Kafka ブローカーと ZooKeeper インスタンスを複数のホストにインストールします。ホストごとにインストール手順を繰り返します。各 ZooKeeper インスタンスとブローカーを識別するには、設定に一意の ID を追加します。詳細は、4章マルチノード環境の実行 を参照してください。
前提条件
- インストールファイル をダウンロードしている。
- Red Hat Enterprise Linux 上の Streams for Apache Kafka 2.7 のリリースノート で、サポートされる構成を確認している。
-
管理者 (
root
) ユーザーとして Red Hat Enterprise Linux にログインしている。
手順
ホストに ZooKeeper を使用して Kafka をインストールします。
新しい
kafka
ユーザーとグループを追加します。groupadd kafka useradd -g kafka kafka passwd kafka
amq-streams-<version>-bin.zip
ファイルの内容を抽出して/opt/kafka
ディレクトリーに移動します。unzip amq-streams-<version>-bin.zip -d /opt mv /opt/kafka*redhat* /opt/kafka
/opt/kafka
ディレクトリーの所有権をkafka
ユーザーに変更します。chown -R kafka:kafka /opt/kafka
ZooKeeper データを格納する
/var/lib/zookeeper
ディレクトリーを作成し、その所有権をkafka
ユーザーに設定します。mkdir /var/lib/zookeeper chown -R kafka:kafka /var/lib/zookeeper
Kafka データを格納する
/var/lib/kafka
ディレクトリーを作成し、その所有権をkafka
ユーザーに設定します。mkdir /var/lib/kafka chown -R kafka:kafka /var/lib/kafka
Kafka のデフォルトの設定をシングルノードクラスターとして実行 できるようになりました。
インストールを使用して、Kafka Connect などの他の Kafka コンポーネントを同じホストで実行することもできます。
他のコンポーネントを実行するには、コンポーネント設定の
bootstrap.servers
プロパティーを使用して、Kafka ブローカーに接続するためのホスト名とポートを指定します。同じホスト上の単一の Kafka ブローカーを指すブートストラップサーバー設定の例
bootstrap.servers=localhost:9092
ただし、別のホストに Kafka コンポーネントをインストールして実行することを推奨します。
(オプション) Kafka コンポーネントを個別のホストにインストールします。
-
手順を繰り返して、インストールファイルを展開し、各ホストの
/opt/kafka
ディレクトリーにインストールします。 Kafka ブローカーを実行しているホスト (またはマルチノード環境のホスト) にコンポーネントを接続する
bootstrap.servers
設定を追加します。異なるホスト上の Kafka ブローカーを指すブートストラップサーバー設定の例
bootstrap.servers=kafka0.<host_ip_address>:9092,kafka1.<host_ip_address>:9092,kafka2.<host_ip_address>:9092
この設定は、Kafka Connect、MirrorMaker 2、および Kafka Bridge に使用できます。
-
手順を繰り返して、インストールファイルを展開し、各ホストの