Data
data class DataFlowEndpointKafkaArgs(val batching: Output<DataFlowEndpointKafkaBatchingArgs>? = null, val compression: Output<Either<String, DataFlowEndpointKafkaCompression>>? = null, val consumerGroupId: Output<String>? = null, val copyMqttProperties: Output<Either<String, OperationalMode>>? = null, val host: Output<String>? = null, val kafkaAcks: Output<Either<String, DataFlowEndpointKafkaAcks>>? = null, val partitionStrategy: Output<Either<String, DataFlowEndpointKafkaPartitionStrategy>>? = null, val tls: Output<TlsPropertiesArgs>) : ConvertibleToJava<DataFlowEndpointKafkaArgs>
Kafka endpoint properties
Constructors
Link copied to clipboard
constructor(batching: Output<DataFlowEndpointKafkaBatchingArgs>? = null, compression: Output<Either<String, DataFlowEndpointKafkaCompression>>? = null, consumerGroupId: Output<String>? = null, copyMqttProperties: Output<Either<String, OperationalMode>>? = null, host: Output<String>? = null, kafkaAcks: Output<Either<String, DataFlowEndpointKafkaAcks>>? = null, partitionStrategy: Output<Either<String, DataFlowEndpointKafkaPartitionStrategy>>? = null, tls: Output<TlsPropertiesArgs>)
Properties
Link copied to clipboard
Batching configuration.
Link copied to clipboard
Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
Link copied to clipboard
Consumer group ID.
Link copied to clipboard
Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
Link copied to clipboard
Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
Link copied to clipboard
Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
Link copied to clipboard
TLS configuration.