DataflowEndpointKafka interface

Kafka エンドポイントのプロパティ

プロパティ

authentication

認証の構成。 注 - エントリごとに認証プロパティのみが許可されます。

batching

バッチ処理の構成。

cloudEventAttributes

クラウド イベント マッピングの構成。

compression

圧縮。 none、gzip、lz4、または snappy を指定できます。 エンドポイントがソースとして使用されている場合、影響はありません。

consumerGroupId

コンシューマー グループ ID。

copyMqttProperties

ブローカーのプロパティをコピーします。 エンドポイントがソースとして使用されている場合、またはデータフローにブローカー ソースがない場合は影響しません。

host

Kafka エンドポイント ホスト。

kafkaAcks

Kafka acks。 all、one、または 0 を指定できます。 エンドポイントがソースとして使用されている場合、影響はありません。

partitionStrategy

パーティション処理戦略。 既定値または静的にすることができます。 エンドポイントがソースとして使用されている場合、影響はありません。

tls

TLS 構成。

プロパティの詳細

authentication

認証の構成。 注 - エントリごとに認証プロパティのみが許可されます。

authentication: DataflowEndpointKafkaAuthentication

プロパティ値

batching

バッチ処理の構成。

batching?: DataflowEndpointKafkaBatching

プロパティ値

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

tls

TLS 構成。

tls?: TlsProperties

プロパティ値