機械翻訳について

トピック&パーティション・ページ

操作の実行対象となる操作およびトピックを選択し、オプションでメッセージ構造を指定します。

起動接続としてのApache Kafkaアダプタの構成

要素 説明

トピックの選択

 操作を実行するトピックを選択します。 トピックの先頭文字を入力して、トピックの表示をフィルタすることもできます。 トピックは、アプリケーションでメッセージを追加、処理および再処理できるカテゴリです。 トピック内のメッセージをサブスクライブします。

パーティションの指定

(このフィールドは、「Kafkaトピックにレコードを公開」または「Kafkaトピックからレコードを消費」を選択した場合にのみ表示されます。)

パーティションを指定します。 Kafkaのトピックは、複数のブローカにわたってデータを分割できるパーティションに分かれています。 特定のパーティションを選択しず、デフォルトの選択を使用する場合、Kafkaでは使用可能なすべてのパーティションが考慮され、使用するパーティションが決定されます。
コンシューマ・グループ

(このフィールドは、「Kafkaトピックからレコードを消費」を選択した場合にのみ表示されます。)

アタッチするコンシューマ・グループを指定します。

コンシューマは、同じグループIDを使用してグループを結合します。 Kafkaは、トピックのパーティションをグループ内のコンシューマに割り当てます。

ノート: デフォルト以外のパーティションを使用する場合は、トピック・パーティションに固有のコンシューマ・グループを指定します。

メッセージを消費するためのオプションの指定

(このフィールドは、「Kafkaトピックからレコードを消費」を選択した場合にのみ表示されます。)

  • 最新の読取り: 統合がアクティブ化された時間から始まる最新のメッセージを読み取ります。
  • 開始から読取り: メッセージを最初から読み取る場合に選択します。

    たとえば、最初から読み取ることを選択し、統合をアクティブ化した場合、最初のスケジュール済実行では20レコードを取得し、次にスケジュールされている実行では次の20件のレコードを取得します。 統合が非アクティブ化、編集および再アクティブ化された場合、次の20レコードが選択されます。

  • 特定のオフセットからの読取り: コンシューマを特定のオフセット(パーティション固有)にリセットする場合に選択します。 「追加」をクリックして、パーティションおよびオフセットを追加します。
構成後、再度編集すると、次のオプションが表示されます:
  • 続きを読む: 非アクティブ化の前に次のメッセージを中断した場所から読み取ります。
  • 最初にリセット: メッセージを最初から再度読み取ります(重複の原因になる可能性があります)。
  • 特定のオフセットからの読取り: コンシューマを特定のオフセット(パーティション固有)にリセットする場合に選択します。 「追加」をクリックして、パーティションおよびオフセットを追加します(重複が発生する可能性があります)。
ノート:
  • 「最初から読む」、「最新情報を読む」、または「特定のオフセットからの読取り」を選択すると、すべてのメッセージが1回の実行で消費されるとは限りません。 ただし、残りのメッセージは後続の実行で消費されます。
  • 「最初から読む」、「開始時にリセット」または「特定のオフセットからの読取り」を選択すると、ウィザードの完了時にコンシューマ・グループ・オフセットがリセットされます。
フェッチする最大レコード数

(このフィールドは、「Kafkaトピックからレコードを消費」または「オフセットを指定することでKafkaトピックからのレコードを消費」を選択した場合にのみ表示されます。)

読み込むメッセージの数を指定します。 完了メッセージ・ペイロードのしきい値は10 MBです。

ノート: このフィールドは、フェッチするレコードの上限を指定します。 1回の実行でストリームから取得するレコード数を指定しても保証されません。 残りのメッセージは、後続の実行でフェッチされます。

メッセージ構造を指定しますか。

 ウィザードの「メッセージ構造」ページで使用するメッセージ構造を定義する場合は、「はい」を選択します。 それ以外の場合は、「いいえ」を選択します。

ノート: 「いいえ」を選択した場合は、不透明なスキーマの拡張オプションでメッセージ・タイプ値をOpaque(Base64binary)として指定します。

メッセージのヘッダーを指定しますか。

 ウィザードのヘッダー・ページで使用するメッセージ・ヘッダーを定義する場合は、「はい」を選択します。 それ以外の場合は、「いいえ」を選択します。
拡張構成のレビューおよび更新 「編集」をクリックして「拡張オプション」セクションを開き、トランザクション・プロデューサを有効または無効にします。
  1. トランザクション・プロデューサ: このフィールドは、Kafkaトピックにレコードを公開を選択した場合にのみ表示されます。 このオプションは、次の機能を提供します:
    1. 選択すると、トランザクション・プロデューサにより、アプリケーションから複数のパーティションにメッセージを原子的に送信できます。
    2. 選択しない場合、「Apache Kafkaアダプタ」は非トランザクション・プロデューサとして構成されます。
  2. メッセージ・タイプ: メッセージ・タイプを定義します。 使用可能なオプションは、「文字列」または「バイト」です。 メッセージに使用するシリアライザを定義します。 この選択は、メッセージ・キーと値に適用されます。

トリガー接続としてのApache Kafkaアダプタの構成

要素 説明

トピックの選択

 操作を実行するトピックを選択します。 トピックの先頭文字を入力して、トピックの表示をフィルタすることもできます。 トピックは、アプリケーションでメッセージを追加、処理および再処理できるカテゴリです。 トピック内のメッセージをサブスクライブします。

パーティションの指定

(このフィールドは、KafkaコンシューマAPIを使用してトピックからデータを読み取る場合にのみ表示されます。)

選択したトピックをプッシュするパーティションを指定します。 Kafkaのトピックは、複数のブローカにわたってデータを分割できるパーティションに分かれています。 特定のパーティションを選択せずに「デフォルト」の選択を使用すると、Kafkaは使用可能なすべてのパーティションを考慮して、使用するパーティションを決定します。
コンシューマ・グループ

(このフィールドは、KafkaコンシューマAPIを使用してトピックからデータを読み取る場合にのみ表示されます。)

アタッチするコンシューマ・グループを指定します。

コンシューマは、同じグループIDを使用してグループを結合します。 Kafkaは、トピックのパーティションをグループ内のコンシューマに割り当てます。

ノート: デフォルト以外のパーティションを使用する場合は、トピック・パーティションに固有のコンシューマ・グループを指定します。

メッセージを消費するためのオプションの指定
  • 最新の読取り: 統合がアクティブ化された時間から始まる最新のメッセージを読み取ります。
  • 開始から読取り: メッセージを最初から読み取る場合に選択します。
  • 特定のオフセットからの読取り: コンシューマを特定のオフセット(パーティション固有)にリセットする場合に選択します。 「追加」をクリックして、パーティションおよびオフセットを追加します。
構成後、再度編集すると、次のオプションが表示されます:
  • 続きを読む: 非アクティブ化の前に次のメッセージを中断した場所から読み取ります。
  • 最初にリセット: メッセージを最初から再度読み取ります(重複の原因になる可能性があります)。
  • 特定のオフセットからの読取り: コンシューマを特定のオフセット(パーティション固有)にリセットする場合に選択します。 「追加」をクリックして、パーティションおよびオフセットを追加します(重複が発生する可能性があります)。
ノート:
  • 「最初から読む」、「最新情報を読む」、または「特定のオフセットからの読取り」を選択すると、すべてのメッセージが1回の実行で消費されるとは限りません。 ただし、残りのメッセージは後続の実行で消費されます。
  • 「最初から読む」、「開始時にリセット」または「特定のオフセットからの読取り」を選択すると、ウィザードの完了時にコンシューマ・グループ・オフセットがリセットされます。
アプリケーションID

(このフィールドは、KafkaストリーミングAPIを使用してトピックからデータを読み取る場合にのみ表示されます。)

 添付するアプリケーションIDを指定します。 ストリームには一意のIDが必要です。
Polling Frequency (Sec)

(このフィールドは、KafkaコンシューマAPIを使用してトピックからデータを読み取る場合にのみ表示されます。)

レコードをフェッチする頻度を指定します。

ノート: トリガー・ベースのポーリングでは、最大10分間隔がサポートされています。

メッセージをデバッチ処理しますか? メッセージをデバッチ処理する場合は、「はい」を選択します。 Debatchでは、トラッキング・インスタンスごとに発生するメッセージの最大数を選択できます。 それ以外の場合は、「いいえ」を選択します。
フェッチする最大レコード数

(このフィールドは、KafkaコンシューマAPIを使用してトピックからデータを読み取る場合にのみ表示されます。)

読み込むメッセージの数を指定します。 完了メッセージ・ペイロードのしきい値は10 MBです。

ノート: このフィールドは、フェッチするレコードの上限を指定します。 1回の実行でストリームから取得するレコード数を指定しても保証されません。 残りのメッセージは、後続の実行でフェッチされます。

インスタンスごとに発生するレコードの最大数

(このフィールドは、「デバッチ」が選択されている場合にのみ表示されます。)

Oracle Integrationで、トラッキング・インスタンスごとに生成されるレコードの最大数を指定します。

メッセージ構造を指定しますか。

 ウィザードの「メッセージ構造」ページで使用するメッセージ構造を定義する場合は、「はい」を選択します。 それ以外の場合は、「いいえ」を選択します。

メッセージのヘッダーを指定しますか。

 ウィザードのヘッダー・ページで使用するメッセージ・ヘッダーを定義する場合は、「はい」を選択します。 それ以外の場合は、「いいえ」を選択します。
拡張構成のレビューおよび更新 「編集」をクリックして、「拡張オプション」セクションを開きます。
  1. メッセージ・タイプ: メッセージ・タイプを定義します。 使用可能なオプションは、「文字列」または「バイト」です。 メッセージに使用するシリアライザを定義します。 この選択は、メッセージ・キーと値に適用されます。
否認済メッセージ(DLQ)構成のレビューおよび更新 却下されたメッセージのトピックを定義します。 却下されたメッセージのコピー先となるトピックを選択できます。