Dataflow
data class DataflowEndpointKafkaResponse(val authentication: DataflowEndpointKafkaAuthenticationResponse, val batching: DataflowEndpointKafkaBatchingResponse? = null, val cloudEventAttributes: String? = null, val compression: String? = null, val consumerGroupId: String? = null, val copyMqttProperties: String? = null, val host: String, val kafkaAcks: String? = null, val partitionStrategy: String? = null, val tls: TlsPropertiesResponse? = null)
Kafka endpoint properties
Constructors
Link copied to clipboard
constructor(authentication: DataflowEndpointKafkaAuthenticationResponse, batching: DataflowEndpointKafkaBatchingResponse? = null, cloudEventAttributes: String? = null, compression: String? = null, consumerGroupId: String? = null, copyMqttProperties: String? = null, host: String, kafkaAcks: String? = null, partitionStrategy: String? = null, tls: TlsPropertiesResponse? = null)
Properties
Link copied to clipboard
Authentication configuration. NOTE - only authentication property is allowed per entry.
Link copied to clipboard
Batching configuration.
Link copied to clipboard
Cloud event mapping config.
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
Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
Link copied to clipboard
TLS configuration.