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 クラスターからのテストメッセージが消費されます。