DataflowEndpointKafka interface
Kafka エンドポイントのプロパティ
プロパティ
| authentication | 認証の構成。 注 - エントリごとに認証プロパティのみが許可されます。 |
| batching | バッチ処理の構成。 |
| cloud |
クラウド イベント マッピングの構成。 |
| compression | 圧縮。 none、gzip、lz4、または snappy を指定できます。 エンドポイントがソースとして使用されている場合、影響はありません。 |
| consumer |
コンシューマー グループ ID。 |
| copy |
ブローカーのプロパティをコピーします。 エンドポイントがソースとして使用されている場合、またはデータフローにブローカー ソースがない場合は影響しません。 |
| host | Kafka エンドポイント ホスト。 |
| kafka |
Kafka acks。 all、one、または 0 を指定できます。 エンドポイントがソースとして使用されている場合、影響はありません。 |
| partition |
パーティション処理戦略。 既定値または静的にすることができます。 エンドポイントがソースとして使用されている場合、影響はありません。 |
| tls | TLS 構成。 |
プロパティの詳細
authentication
認証の構成。 注 - エントリごとに認証プロパティのみが許可されます。
authentication: DataflowEndpointKafkaAuthentication
プロパティ値
batching
cloudEventAttributes
クラウド イベント マッピングの構成。
cloudEventAttributes?: string
プロパティ値
string
compression
圧縮。 none、gzip、lz4、または snappy を指定できます。 エンドポイントがソースとして使用されている場合、影響はありません。
compression?: string
プロパティ値
string
consumerGroupId
コンシューマー グループ ID。
consumerGroupId?: string
プロパティ値
string
copyMqttProperties
ブローカーのプロパティをコピーします。 エンドポイントがソースとして使用されている場合、またはデータフローにブローカー ソースがない場合は影響しません。
copyMqttProperties?: string
プロパティ値
string
host
Kafka エンドポイント ホスト。
host: string
プロパティ値
string
kafkaAcks
Kafka acks。 all、one、または 0 を指定できます。 エンドポイントがソースとして使用されている場合、影響はありません。
kafkaAcks?: string
プロパティ値
string
partitionStrategy
パーティション処理戦略。 既定値または静的にすることができます。 エンドポイントがソースとして使用されている場合、影響はありません。
partitionStrategy?: string
プロパティ値
string