Dataflow
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)