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

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

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

    始める前に

    必要なロール：admin

    このタスクについて

    次の手順では、プロデューサークライアントを設定し、Hermes Kafka クラスターにテストメッセージを送信する方法について説明します。ビジネスまたは本番目的で 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/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> - キーストアファイルへのパスで
    4. テストトピックを生成します。
      1. 次のコマンドを実行します。
        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> を一意のテストトピック名に
        注:
        トピック名の各部分は大文字と小文字を区別します。
      2. テストトピックにテストメッセージを送信します。
        例：
        test1
test2
test3

    タスクの結果

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

    次のタスク

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