コンポーネントのsetSettings {}関数で定義できるジョブスクリプトの関数とパラメーターは、以下の表のとおりです。
| 関数/パラメーター | 説明 | 必須? |
|---|---|---|
|
USE_EXISTING_CONNECTION |
定義済みの接続情報を再利用する場合は、このパラメーターをtrueに設定して、CONNECTIONパラメーターを使って、関連接続コンポーネント名を指定します。 |
いいえ |
|
BROKER_LIST |
"\"host1:port1、host2:port2、...\""の形式で、使用されるKafkaクラスターのブローカーノードのアドレスを指定します。 このパラメーターは、KafkaクラスターバージョンがKafka 0.9.2.1以上である場合、有効です。 |
はい |
|
AUTO_OFFSET_RESET |
消費されるトピックメッセージの開始ポイントを指定します。使用できる値は次のとおりです。
|
いいえ |
|
KAFKA_TOPIC |
このコンポーネントがメッセージフィードを受け取るトピック名を指定します。 |
はい |
|
GROUP_ID |
現在のコンシューマーが属すコンシューマーグループの名前を指定します。 この時点でこのコンシューマーグループが存在していない場合、実行時に作成されます。 |
はい |
|
KAFKA_MAX_RATE_PER_ PARTITION_CHECK |
必要に応じて、このパラメーターをtrueに設定し、KAFKA_MAX_RATE_PER_PARTITIONパラメーターを使って、処理用にバッチ単位で送信される最大メッセージ数を指定できます。 デフォルトでは、このパラメーターはfalseに設定されます。この場合、1秒間で単一のバッチに全メッセージが読み込まれますが、大量のメッセージのためにジョブが応答しなくなる可能性があります。 |
いいえ |
|
USE_HTTPS |
SSLまたはTLSの暗号化を有効にする場合はこのパラメーターをtrueに設定し、HTTPS_SETTINGパラメーターを使って、暗号化情報を定義するのに使用するtSetKeystoreコンポーネントを指定します。 |
いいえ |
|
USE_KRB |
使用するKafkaクラスターをKerberosで保護する場合、このパラメーターをtrueに設定し、次のパラメーターを使って関連セキュリティ情報を定義します。
|
いいえ |
|
KAFKA_CONSUMER_ PROPERTIES {} |
Kafkaコンシューマーのカスタム設定を使用する必要がある場合、この関数に、次のパラメーターセットを1つ以上含めて、カスタマイズするプロパティを指定します。カスタマイズされたプロパティは、ランタイムに、Studioによって使用される対応するプロパティを上書きします。
|
いいえ |
|
USE_HIERARCHICAL |
指定のバイナリ(階層を含む) Avroスキーマを、現在のコンポーネントのスキーマに定義されているフラットスキーマにマッピングするには、このパラメーターをtrueに設定します。処理するAvroメッセージがフラットである場合は、このメッセージをfalseに設定します(デフォルト)。このパラメーターをtrueに設定する場合、Avroスキーマファイルを指定して、マッピングを定義する必要があります。
|
いいえ |
|
LABEL |
このパラメーターを使って、コンポーネントのテキストラベルを指定します。 |
いいえ |