Kafkaクラスターのインストールとデプロイメント
Kafkaクラスタのインストールとデプロイメントは、以下のような手順に分けることができます。
- Kafkaをダウンロードする：最初に、公式ウェブサイトからKafkaの圧縮ファイルをダウンロードします。適切なバージョンを選択してください。
- ダウンロードした圧縮ファイルを適宜なディレクトリに展開する。
- Zookeeperの配置：KafkaはZookeeperを使用してクラスターを調整します。Kafkaのディレクトリ内のconfigディレクトリにあるzookeeper.propertiesファイルをコピーし、zookeeper.propertiesの名前で保存します。次に、Zookeeper接続のアドレスを指定するために、zookeeper.propertiesファイルの構成を変更します。
- Kafkaの設定：Kafkaディレクトリのconfigディレクトリでserver.propertiesファイルをコピーしてkafka.propertiesにリネームします。次に、kafka.propertiesファイル内の設定を、broker.id（Kafkaノードを識別する一意のID）、listeners（Kafkaのリスニングアドレスとポートを指定）、log.dirs（Kafkaのログディレクトリを指定）などを含めて修正します。
- ZooKeeperの起動：端末ウィンドウを開き、Kafkaディレクトリのbinディレクトリに移動して、次のコマンドを実行してZooKeeperを起動します。
- ../config/zookeeper.propertiesを使用してzookeeper-server-start.shを開始します
- ターミナルウィンドウをもう一つ開いてKafkaディレクトリ内のbinディレクトリに移動し、以下のコマンドを実行してKafkaを起動します。
- ../config/kafka.propertiesを使用して./kafka-server-start.shをネイティブに日本語で言い換える方法は1つだけです。
- クラスタの検証：Kafka 独自の CLI ツールを使用して検証します。最初にトピックを作成します。
- natively –bootstrap-server localhost:9092 –replication-factor 1 –partitions 1 –topic test-topic
- 続いて、メッセージを送信します。
- ネイティブな日本語で文章を言い換えます。1つのオプションのみ必要です。：./kafka-console-producer.sh –bootstrap-server localhost:9092 –topic test-topic
- 最後に、消費ニュースです：
- ./kafka-console-consumer.sh –bootstrap-server localhost:9092 –topic test-topic –from-beginning
- 通常通り動作していれば、発信メッセージは消費者向けのウィンドウから確認できます。
以上は基本的なKafkaクラスタインストール・デプロイ手順であり、具体的な設定や操作は環境によって異なる場合があります。状況に応じて調整してください。
