Kafka クライアントを使用した Hermes トピックへのテストメッセージの生成

プロデューサークライアントを設定して、Hermes トピックへのテストメッセージを生成します。

始める前に

• ServiceNow® インスタンス署名証明書とキーストアを生成して Kafka トピックを保護します。Hermes プロデューサーを構成するときは、トラストストアとキーストアの詳細を指定する必要があります。「Hermes メッセージングサービス への安全な接続の設定」を参照してください。
• Apache Kafka をダウンロードしてインストールします。「Apache Kafka クライアント環境の準備」を参照してください。
• 生成するテストメッセージを格納するテストトピックを作成します。詳細については、「Kafka クライアントを使用した Hermes でのテストトピックの作成」を参照してください。

必要なロール：admin

このタスクについて

次の手順では、プロデューサークライアントを設定し、Hermes Kafka クラスターにテストメッセージを送信する方法について説明します。ビジネスまたは本番目的で Hermes にメッセージを生成する準備ができたら、これらの手順を参照してください。

手順

1. Kafka を展開した config ディレクトリに移動します。
   • Unix の場合の例：

     cd /home/user/Software/kafka/config

   • Windows の場合の例：

     cd C:\Software\kafka\config

2. プロデューサーを構成します。
   1. producer.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. Kafka ディレクトリに移動します。
   2. 次のコマンドを実行します。
      UNIX：

      ./bin/kafka-console-producer.sh --topic snc.<instance_name>.<namespace>.sn_<app_id>.<topic_name> --producer.config ./config/producer.properties --bootstrap-server <instance_name>.service-now.com:4000,<instance_name>.service-now.com:4001,<instance_name>.service-now.com:4002,<instance_name>.service-now.com:4003

      Windows：

      bin/windows/kafka-console-producer.bat --topic snc.<instance_name>.<namespace>.sn_<app_id>.<topic_name> --producer.config config/producer.properties --bootstrap-server <instance_name>.service-now.com:4000,<instance_name>.service-now.com:4001,<instance_name>.service-now.com:4002,<instance_name>.service-now.com:4003

      次のプレースホルダー変数を置き換えます。

      • <instance_name> をインスタンス名で
      • <namespace> を Kafka トピックが属するドメインの名前空間で (オプション)
      • <app_id> をアプリケーション ID に
      • <topic_name> を一意のテストトピック名に

      注:

      トピック名の各部分は大文字と小文字を区別します。
   3. テストトピックにテストメッセージを送信します。
      例：

      test1
      test2
      test3

タスクの結果

Hermes Kafka クラスター内のテストトピックにテストメッセージが生成されます。

次のタスク

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

関連タスク

• Apache Kafka クライアント環境の準備
• Kafka クライアントを使用した Hermes でのテストトピックの作成
• Kafka クライアントを使用した Hermes トピックからのテストメッセージの消費