Kafka クライアントを使用したトピックからの Hermes テストメッセージの消費

  • リリースバージョン: Washingtondc
  • 更新日 2024年02月01日
  • 読む6読むのに数分

    • 2 つのコンシューマークライアントを設定して、Hermes トピックからのテストメッセージを消費します。

    始める前に

    必要なロール：admin

    このタスクについて

    次の手順では、2 つのコンシューマークライアントを設定し、Hermes Kafka クラスターからテストメッセージを受信する方法について説明します。Hermes は Kafka クラスターをペアで使用するため、コンシューマークライアントが 2 つ必要になります。これは、コンシューマーごとに 1 つずつ、2 つの異なるブートストラップアドレスを使用する必要があることを意味します。

    ビジネスまたは本番目的で Hermes からのメッセージを消費する準備ができたら、これらの手順を参照してください。

    手順

    1. Apache Kafka をダウンロードしてインストールします。
      1. をダウンロードする Apache Kafka バイナリ。
      2. 次のコマンドを実行して、Kafka パッケージを展開します。 
        tar -zxvf kafka_2.13-3.1.2.tgz
    2. 次のコマンドを実行して、Kafka ディレクトリに移動します。 
      cd kafka_2.13-3.1.2
    3. コンシューマーを設定します。
      1. config/consumer.properties ファイルを開きます。
      2. 次の SSL プロパティを設定します。 
        security.protocol=SSL

ssl.truststore.password=<truststore password>

ssl.truststore.location=<path to truststore.p12>

ssl.truststore.type=PKCS12

ssl.keystore.password=<keystore password>

ssl.keystore.location=<path to keystore.p12>

ssl.keystore.type=PKCS12

ssl.key.password=<keystore password>
        次のプレースホルダー変数を置き換えます。
        • <truststore password> - トラストストアパスワードで
        • <path to truststore.p12> - トラストストアファイルへのパスで
        • <keystore password> - キーストアパスワードで
        • <path to keystore.p12> - キーストアファイルへのパスで
    4. 各コンシューマーを使用してメッセージを消費します。
      1. 最初のコンシューマークライアントに対して次のコマンドを実行します。
        UNIX：
        ./bin/kafka-console-consumer.sh --consumer.config ./config/consumer.properties --topic snc.<instance_name>.<namespace>.sn_<app_id>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4100,<instance_name>.service-now.com:4101,<instance_name>.service-now.com:4102,<instance_name>.service-now.com:4103
        Windows：
        ./bin/windows/kafka-console-consumer.bat --consumer.config ./config/consumer.properties --topic snc.<instance_name>.<namespace>.sn_<app_id>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4100,<instance_name>.service-now.com:4101,<instance_name>.service-now.com:4102,<instance_name>.service-now.com:4103
        次のプレースホルダー変数を置き換えます。
        • <instance_name> をインスタンス名で
        • <namespace> を Kafka トピックが属するドメインの名前空間で (オプション)
        • <app_id>アプリケーションIDで
        • <topic_name> - テストトピック名で (大文字と小文字を区別)
        • <consumer_group_id> - コンシューマーが属するグループの任意のラベルで (大文字と小文字を区別)
        注:
        トピック名の各部分は大文字と小文字を区別します。
      2. 新しいターミナルウィンドウを開きます。
      3. 2 つめのコンシューマークライアントに対して次のコマンドを実行します。
        UNIX：
        ./bin/kafka-console-consumer.sh --consumer.config ./config/consumer.properties --topic snc.<instance_name>.<namespace>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4200,<instance_name>.service-now.com:4201,<instance_name>.service-now.com:4202,<instance_name>.service-now.com:4203
        Windows：
        ./bin/windows/kafka-console-consumer.bat --consumer.config ./config/consumer.properties --topic snc.<instance_name>.<namespace>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4200,<instance_name>.service-now.com:4201,<instance_name>.service-now.com:4202,<instance_name>.service-now.com:4203
        次のプレースホルダー変数を置き換えます。
        • <instance_name> をインスタンス名で
        • <namespace>Kafka トピックが属するドメインの名前空間で (オプション)
        • <topic_name> - テストトピック名で (大文字と小文字を区別)
        • <consumer_group_id> - コンシューマーが属するグループの任意のラベルで (大文字と小文字を区別)
        注:
        トピック名の各部分は大文字と小文字を区別します。

    タスクの結果

    Hermes Kafka クラスターからのテストメッセージが消費されます。