tKafkaCommitの標準プロパティ
これらのプロパティは、標準ジョブのフレームワークで実行されているtKafkaCommitを設定するために使われます。
標準のtKafkaCommitコンポーネントは、インターネットファミリーに属しています。
このフレームワークのコンポーネントは、すべてのビッグデータ対応のTalend製品およびTalend Data Fabricで利用できます。
基本設定
| [Properties] (プロパティ) | 説明 |
|---|---|
|
[Commit offsets from] (次からオフセットをコミット:) |
消費されたメッセージがコミットされるtKafkaInputコンポーネントを選択します。 |
詳細設定
| [Properties] (プロパティ) | 説明 |
|---|---|
|
[tStatCatcher Statistics] (tStatCatcher統計) |
このチェックボックスをオンにすると、ジョブレベルおよび各コンポーネントレベルで処理メタデータが収集されます。 |
[Global Variables] (グローバル変数)
| 変数 | 説明 |
|---|---|
|
ERROR_MESSAGE |
エラー発生時にコンポーネントによって生成されるエラーメッセージ。これはAfter変数で、文字列を返します。 |
[Global Variables] (グローバル変数)
| 変数 | 説明 |
|---|---|
|
ERROR_MESSAGE |
エラー発生時にコンポーネントによって生成されるエラーメッセージ。これはAfter変数で、文字列を返します。 |
使用方法
| 使用方法のガイダンス | 説明 |
|---|---|
|
使用ルール |
tKafkaCommitは、サブジョブフローの終了コンポーネントとして使うことも、独自のサブジョブとして独立して呼び出すこともできますが、通常はスタンドアロンで使われ、オフセットのバッチを一度にコミットします。オフセットを定期的にコミットする必要がある場合は、 tKafkaInputの自動コミット機能を使うことをお勧めします。 |