2.15.3. トピックの作成

手順

1. 以下の要求形式でトピックを作成します。

   構文

   POST
   Action=CreateTopic
   &Name=TOPIC_NAME
   [&Attributes.entry.1.key=amqp-exchange&Attributes.entry.1.value=EXCHANGE]
   [&Attributes.entry.2.key=amqp-ack-level&Attributes.entry.2.value=none|broker|routable]
   [&Attributes.entry.3.key=verify-ssl&Attributes.entry.3.value=true|false]
   [&Attributes.entry.4.key=kafka-ack-level&Attributes.entry.4.value=none|broker]
   [&Attributes.entry.5.key=use-ssl&Attributes.entry.5.value=true|false]
   [&Attributes.entry.6.key=ca-location&Attributes.entry.6.value=FILE_PATH]
   [&Attributes.entry.7.key=OpaqueData&Attributes.entry.7.value=OPAQUE_DATA]
   [&Attributes.entry.8.key=push-endpoint&Attributes.entry.8.value=ENDPOINT]
   [&Attributes.entry.9.key=persistent&Attributes.entry.9.value=true|false]

   リクエストパラメーターを以下に示します。

   • Endpoint: 通知を送信するエンドポイントの URL。
   • OpaqueData: 不透明なデータはトピック設定で設定され、トピックによって発生するすべての通知に追加されます。
   • persistent: このエンドポイントへの通知が永続的 (非同期) であるかを示します。デフォルト値は false です。

   • HTTP エンドポイント:

     • URL: https://FQDN:PORT
     • port defaults to: HTTP または HTTPS にそれぞれ 80 または 443 を使用します。
     • verify-ssl: サーバー証明書がクライアントによって検証されているかどうかを示します。デフォルトでは true です。

   • AMQP0.9.1 エンドポイント:

     • URL: amqp://USER:PASSWORD@FQDN:PORT[/VHOST].
     • ユーザーおよびグループのデフォルト値はそれぞれ guest と guest です。
     • ユーザーおよびパスワードの詳細は HTTPS 経由で提供する必要があります。そうしないと、トピック作成要求は拒否されます。
     • Port のデフォルト値 は 5672 です。
     • vhost のデフォルトは “/” です。
     • amqp-exchange: 交換は存在し、トピックに基づいてメッセージをルーティングできる必要があります。これは AMQP0.9.1 の必須パラメーターです。同じエンドポイントを参照するさまざまなトピックが同じ交換を使用する必要があります。

     • amqp-ack-level: 最終宛先に送信される前にメッセージがブローカーで永続化される可能性があるため、終了確認は不要です。承認メソッドは 3 つあります。

       • none: ブローカーに送信された場合にメッセージが 配信されている と見なされます。
       • broker: デフォルトでは、メッセージはブローカーによって確認応答されると 配信されている と見なされます。

       • routable: ブローカーがコンシューマーにルーティングできる場合、メッセージは 配信されている と見なされます。

         注記

         特定のパラメーターのキーと値は、同じ行または特定の順序で存在する必要はありませんが、同じインデックスを使用する必要があります。属性インデックスは、特定の値から順番にしたり、開始したりする必要はありません。

         注記

         topic-name は AMQP トピックに使用されます。

   • Kafka エンドポイント:

     • URL: kafka://USER:PASSWORD@FQDN:PORT.
     • use-ssl がデフォルトで false に設定される場合。use-ssl が true に設定されている場合は、ブローカーへの接続にセキュアな接続が使用されます。
     • ca-location が指定され、セキュアな接続が使用される場合は、ブローカーを認証するために、デフォルトの CA ではなく、指定された CA が使用されます。
     • ユーザーおよびパスワードは HTTP[S] でのみ提供できます。そうしないと、トピック作成要求は拒否されます。
     • ユーザーおよびパスワードは use-ssl とのみ提供でき、ブローカーへの接続に失敗していました。
     • Port のデフォルト値 は 9092 です。

     • kafka-ack-level: 最終宛先に送信される前にメッセージがブローカーで永続化される可能性があるため、終了確認は不要です。承認メソッドは 2 つあります。

       • none: ブローカーに送信された場合にメッセージが 配信されている と見なされます。
       • broker: デフォルトでは、メッセージはブローカーによって確認応答されると 配信されている と見なされます。