トピックのデータをコンシュームするには、次の要求構文を使用します。

{
"aggregated": <value>
}

<value>

は、次のいずれかの値をとります。

true。サブスクリプションは、各API呼び出しで使用可能なすべてのパブリケーションをコンシュームします。
false。サブスクリプションは、各API呼び出しで最も古いパブリケーションのみをコンシュームします。

{
"aggregated": true
}

複数のパブリケーションを実行する場合、特定のパブリケーションのパブリケーションイベントIDを要求本文に追加して、特定のパブリケーションイベントのデータのみをコンシュームできます。要求本文に追加できるパブリケーションイベントIDは1つだけです。キー

"publicationEventId"

には大文字小文字の区別があります。特定のパブリケーションのパブリケーションイベントIDを要求本文に追加しない場合、サブスクリプションは使用可能なすべてのパブリケーションイベントをコンシュームします。

{
			"publicationEventId" : "<publicationEventId>"
}  

{
			"publicationEventId" : "594210"
}  

以前に処理されたデータを再コンシュームするには、次の要求構文を使用します。

{
			"requestType" : "RECONSUME",
			"eventId" : "<subscriptionEventId>"
}  

ここで、キー

"eventId"

は再コンシュームするサブスクリプションイベントIDです。

{
			"requestType" : "RECONSUME",
			"eventId" : "40559"
}  

失敗したサブスクリプションを再処理するには、次の要求構文を使用します。

{
			"requestType" : "REPROCESS",
			"eventId" : "<subscriptionEventId>"
}  

ここで、キー

"eventId"

は再処理するサブスクリプションイベントIDです。

{
			"requestType" : "REPROCESS",
			"eventId" : "40577"
}