ストリーム&パーティション・ページ

トリガーとしての「Oracle Cloud Infrastructureストリーミング・サービス・アダプタ」の構成(インバウンド)

要素	説明
ストリームを選択	操作を実行するストリームを選択します。トピックの開始文字を入力して、ストリームの表示をフィルタすることもできます。ストリームは、アプリケーションがメッセージを追加、処理および再処理できるカテゴリです。ストリーム内のメッセージをサブスクライブします。
パーティションの指定	選択したストリームをプッシュするパーティションを指定します。 Oracle Cloud Infrastructure Streaming Serviceストリームはパーティションに分割され、複数のブローカ間でデータを分割できます。特定のパーティションを選択せずに「デフォルト」の選択を使用すると、Oracle Cloud Infrastructure Streaming Serviceでは使用可能なすべてのパーティションが考慮され、使用するパーティションが決定されます。
コンシューマ・グループ	アタッチするコンシューマ・グループを指定します。コンシューマは、同じグループIDを使用してグループを結合します。 Oracle Cloud Infrastructure Streaming Serviceは、ストリームのパーティションをグループ内のコンシューマに割り当てます。単一のコンシューマ・グループを指定してメッセージの重複を防ぐことで、コンシューマ・グループをロード・バランサとして使用できます。また、複数のコンシューマ・グループをカンマで区切って指定して、すべてのグループが同じメッセージを受信するようにすることもできます。
ポーリング頻度(秒)	レコードをポーリングする頻度を秒単位で指定します。
取得レコードの最大数	フェッチするレコードの最大数を指定します。ノート: このフィールドは、フェッチするレコードの上限を指定します。 1回の実行でストリームから取得するレコード数を指定しても保証されません。残りのメッセージは、後続の実行でフェッチされます。
メッセージ構造を指定しますか。	ウィザードの「メッセージ構造」ページで使用するメッセージ構造を定義する場合は、「はい」を選択します。それ以外の場合は「いいえ」を選択します。
メッセージのヘッダーを指定しますか。	ウィザードのヘッダー・ページで使用するメッセージ・ヘッダーを定義する場合は、「はい」を選択します。それ以外の場合は「いいえ」を選択します。
拡張構成のレビューおよび更新	「編集」をクリックして「拡張オプション」セクションを開き、メッセージ・タイプ(文字列またはバイト)を選択します。このアクションにより、メッセージに使用するシリアライザが定義されます。この選択は、メッセージ・キーと値に適用されます。

起動(アウトバウンド)としての「Oracle Cloud Infrastructureストリーミング・サービス・アダプタ」の構成

要素	説明
ストリームを選択	操作を実行するストリームを選択します。トピックの開始文字を入力して、ストリームの表示をフィルタすることもできます。ストリームは、アプリケーションがメッセージを追加、処理および再処理できるカテゴリです。ストリーム内のメッセージをサブスクライブします。
パーティションの指定	選択したストリームをプッシュするパーティションを指定します。 Oracle Cloud Infrastructure Streaming Serviceストリームはパーティションに分割され、複数のブローカ間でデータを分割できます。特定のパーティションを選択せずに「デフォルト」の選択を使用すると、Oracle Cloud Infrastructure Streaming Serviceでは使用可能なすべてのパーティションが考慮され、使用するパーティションが決定されます。ノート: 操作ページでオフセットを指定してストリームからのメッセージを消費を選択した場合、このフィールドは表示されません。
コンシューマ・グループ (このフィールドは、「ストリームからのメッセージの消費」を選択した場合にのみ表示されます。)	アタッチするコンシューマ・グループを指定します。コンシューマは、同じグループIDを使用してグループを結合します。 Oracle Cloud Infrastructure Streaming Serviceは、ストリームのパーティションをグループ内のコンシューマに割り当てます。単一のコンシューマ・グループを指定してメッセージの重複を防ぐことで、コンシューマ・グループをロード・バランサとして使用できます。また、複数のコンシューマ・グループをカンマで区切って指定して、すべてのグループが同じメッセージを受信するようにすることもできます。
メッセージを消費するためのオプションの指定 (このフィールドは、「ストリームからのメッセージの消費」を選択した場合にのみ表示されます。)	最新の読取り: 統合がアクティブ化された時間から始まる最新のメッセージを読み取ります。開始から読取り: メッセージを最初から読み取る場合に選択します。たとえば、最初から読み取ることを選択し、統合をアクティブ化した場合、最初のスケジュール済実行では20レコードを取得し、次にスケジュールされている実行では次の20件のレコードを取得します。統合が非アクティブ化、編集および再アクティブ化された場合、次の20レコードが選択されます。
メッセージ構造を指定しますか。	ウィザードの「メッセージ構造」ページで使用するメッセージ構造を定義する場合は、「はい」を選択します。それ以外の場合は「いいえ」を選択します。
メッセージのヘッダーを指定しますか。	ウィザードのヘッダー・ページで使用するメッセージ・ヘッダーを定義する場合は、「はい」を選択します。それ以外の場合は「いいえ」を選択します。
拡張構成のレビューおよび更新	「編集」をクリックして「拡張オプション」セクションを開き、メッセージ・タイプ(文字列またはバイト)を選択します。このアクションにより、メッセージに使用するシリアライザが定義されます。この選択は、メッセージ・キーと値に適用されます。