Kafka に公開するときに個々のデータセットのタスク設定をオーバーライドする
Kafka に公開するときに、個々のデータセットのデータ メッセージの公開とメッセージ形式のタスク設定をオーバーライドできます。
これを実行するには、次の手順に従います。
-
タスクを開きます。[データセット] タブで、データセットの右側にある
メニューをクリックし、 [設定] を選択します。[データセット設定: <データセット名>] ダイアログが開きます。
-
データ メッセージの公開設定をオーバーライドするには、 [データメッセージの公開] タブを選択し、以下の データ メッセージの公開設定のオーバーライド で説明されているとおりに続行します。
-
メッセージ形式の設定をオーバーライドするには、 [メッセージ形式] タブを選択し、以下の メッセージ形式の設定のオーバーライド で説明されているとおりに続行します。
データ メッセージの公開設定のオーバーライド
各設定について、現在のタスク設定は [タスク設定: <設定>] 項目で示されます (例: タスク設定: 特定のトピック)。
これらの設定の説明については、「データ メッセージの公開」を参照してください。
タスク設定を保持するか、式ビルダーを使用してカスタム トピック、メッセージ キー、またはパーティション キーを指定できます。
式ビルダーを使用するには:
-
必要に応じて、 [カスタム トピック]、 [カスタム メッセージ キー]、または [カスタム パーティション キー] 項目を選択し、
をクリックします。情報メモカスタム トピックがすでに存在しているか、ブローカーがトピックを作成するように構成されている必要があります。式ビルダーが開きます。
-
式をビルドします。
データセット内の列、関数、および演算子を使用して式を作成できます。
をクリックして項目を式に移動します。Kafka でサポートされているすべての関数を式で使用することもできます。
-
[パラメーターの抽出] をクリックします。
すべてのパラメーターについて、テストする値にテスト値を追加できるようになりました。
-
[式をテスト] をクリックします。
テスト値を使用した、式の結果が表示されるはずです。
-
準備ができたら、[OK]をクリックします。
式が項目に追加されます。
式の構築
カスタム値を定義する式を作成する必要があります。以下を使用できます。
-
列
ソース データセットのすべての列。
-
関数
文字列関数、数値関数、null チェック関数、日時関数、および論理関数。
-
演算子
数学および論理演算子。一部の演算子は、式の上のツールバーでも使用できます。これは、文字列連結の演算子 || を見つける場所でもあります。
をクリックして項目を式に移動します。
Kafka でサポートされているすべての関数を式で使用することもできます。
メッセージ形式の設定のオーバーライド
このデータセットのタスク メッセージ属性をオーバーライドするには、 [カスタム設定を使用] を有効にし、メッセージの属性 で説明されているように設定を構成します。