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

  • リリースバージョン: Yokohama
  • 更新日 2025年01月30日
  • 所要時間：6分

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

    始める前に

    必要なロール：admin

    このタスクについて

    次の手順では、2 つのコンシューマークライアントを設定し、Hermes Kafka クラスターからテストメッセージを受信する方法について説明します。Hermes は Kafka クラスターのペアを使用するため、別々のコンシューマーブートストラップアドレスを持つ 2 つのコンシューマークライアントを構成する必要があります。これにより、メッセージを削除せずに両方のクラスターからメッセージが消費されます。

    重要:
    コンシューマークライアントごとに 1 つずつ、2 つの異なるコンシューマーブートストラップアドレスを設定する必要があります。

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

    手順

    1. Kafka を展開した config ディレクトリに移動します。
      • Unix の場合の例：
        cd /home/user/Software/kafka/config
      • Windows の場合の例：
        cd C:\Software\kafka\config
    2. コンシューマーを設定します。
      1. 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> - キーストアファイルへのパスで
      3. 変更内容をプレーンテキストで保存します。
    3. 各コンシューマーを使用してメッセージを消費します。
      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. Kafka ディレクトリに移動します。
      4. 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 クラスターからのテストメッセージが消費されます。