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

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

要素	説明
トピックの選択	操作を実行するトピックを選択します。トピックの先頭文字を入力して、トピックの表示をフィルタすることもできます。トピックは、アプリケーションでメッセージを追加、処理および再処理できるカテゴリです。トピック内のメッセージをサブスクライブします。
パーティションの指定 (このフィールドは、「Kafkaトピックにレコードを公開」または「Kafkaトピックからレコードを消費」を選択した場合にのみ表示されます。)	選択したトピックをプッシュするパーティションを指定します。 Kafkaのトピックは、複数のブローカにわたってデータを分割できるパーティションに分かれています。特定のパーティションを選択せずに「デフォルト」の選択を使用すると、Kafkaは使用可能なすべてのパーティションを考慮して、使用するパーティションを決定します。
コンシューマ・グループ (このフィールドは、「Kafkaトピックからレコードを消費」を選択した場合にのみ表示されます。)	アタッチするコンシューマ・グループを指定します。コンシューマは、同じグループIDを使用してグループを結合します。 Kafkaは、トピックのパーティションをグループ内のコンシューマに割り当てます。
メッセージを消費するためのオプションの指定 (このフィールドは、「Kafkaトピックからレコードを消費」を選択した場合にのみ表示されます。)	最新の読取り: 統合がアクティブ化された時間から始まる最新のメッセージを読み取ります。開始から読取り: メッセージを最初から読み取る場合に選択します。たとえば、最初から読み取ることを選択し、統合をアクティブ化した場合、最初のスケジュール済実行では20レコードを取得し、次にスケジュールされている実行では次の20件のレコードを取得します。統合が非アクティブ化、編集および再アクティブ化された場合、次の20レコードが選択されます。構成後、再度編集すると、次のオプションが表示されます: 最初にリセット: メッセージを最初から再度読み取ります(重複の原因になる可能性があります)。続きを読む: 非アクティブ化の前に次のメッセージを中断した場所から読み取ります。ノート: 開始から読取りまたは最新の読取りオプションを選択すると、すべてのメッセージが1回の実行で確実に使用されるわけではありません。ただし、残りのメッセージは後続の実行で消費されます。
取得レコードの最大数 (このフィールドは、「Kafkaトピックからレコードを消費」または「オフセットを指定することでKafkaトピックからのレコードを消費」を選択した場合にのみ表示されます。)	読み込むメッセージの数を指定します。完了メッセージ・ペイロードのしきい値は10 MBです。ノート: このフィールドは、フェッチするレコードの上限を指定します。 1回の実行でストリームから取得するレコード数を指定しても保証されません。残りのメッセージは、後続の実行でフェッチされます。
メッセージ構造を指定しますか。	ウィザードの「メッセージ構造」ページで使用するメッセージ構造を定義する場合は、「はい」を選択します。それ以外の場合は「いいえ」を選択します。
メッセージのヘッダーを指定しますか。	ウィザードのヘッダー・ページで使用するメッセージ・ヘッダーを定義する場合は、「はい」を選択します。それ以外の場合は「いいえ」を選択します。
拡張構成のレビューおよび更新	「編集」をクリックして「拡張オプション」セクションを開き、トランザクション・プロデューサを有効または無効にします。トランザクション・プロデューサ : このオプションは、次の機能を提供します: 選択すると、トランザクション・プロデューサにより、アプリケーションから複数のパーティションにメッセージを原子的に送信できます。選択しない場合、「Apache Kafkaアダプタ」は非トランザクション・プロデューサとして構成されます。メッセージ・タイプ: メッセージ・タイプを定義します。使用可能なオプションは、「文字列」または「バイト」です。メッセージに使用するシリアライザを定義します。この選択は、メッセージ・キーと値に適用されます。

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

要素	説明
トピックの選択	操作を実行するトピックを選択します。トピックの先頭文字を入力して、トピックの表示をフィルタすることもできます。トピックは、アプリケーションでメッセージを追加、処理および再処理できるカテゴリです。トピック内のメッセージをサブスクライブします。
パーティションの指定	選択したトピックをプッシュするパーティションを指定します。 Kafkaのトピックは、複数のブローカにわたってデータを分割できるパーティションに分かれています。特定のパーティションを選択せずに「デフォルト」の選択を使用すると、Kafkaは使用可能なすべてのパーティションを考慮して、使用するパーティションを決定します。
コンシューマ・グループ	アタッチするコンシューマ・グループを指定します。コンシューマは、同じグループIDを使用してグループを結合します。 Kafkaは、トピックのパーティションをグループ内のコンシューマに割り当てます。
Polling Frequency (Sec)	レコードをフェッチする頻度を指定します。
取得レコードの最大数	読み込むメッセージの数を指定します。完了メッセージ・ペイロードのしきい値は10 MBです。ノート: このフィールドは、フェッチするレコードの上限を指定します。 1回の実行でストリームから取得するレコード数を指定しても保証されません。残りのメッセージは、後続の実行でフェッチされます。
メッセージ構造を指定しますか。	ウィザードの「メッセージ構造」ページで使用するメッセージ構造を定義する場合は、「はい」を選択します。それ以外の場合は「いいえ」を選択します。
メッセージのヘッダーを指定しますか。	ウィザードのヘッダー・ページで使用するメッセージ・ヘッダーを定義する場合は、「はい」を選択します。それ以外の場合は「いいえ」を選択します。
拡張構成のレビューおよび更新	「編集」をクリックして「拡張オプション」セクションを開き、トランザクション・プロデューサを有効または無効にします。トランザクション・プロデューサ : このオプションは、次の機能を提供します: 選択すると、トランザクション・プロデューサにより、アプリケーションから複数のパーティションにメッセージを原子的に送信できます。選択しない場合、「Apache Kafkaアダプタ」は非トランザクション・プロデューサとして構成されます。メッセージ・タイプ: メッセージ・タイプを定義します。使用可能なオプションは、「文字列」または「バイト」です。メッセージに使用するシリアライザを定義します。この選択は、メッセージ・キーと値に適用されます。