Dataflow
constructor(authentication: Output<DataflowEndpointKafkaAuthenticationArgs>, batching: Output<DataflowEndpointKafkaBatchingArgs>? = null, cloudEventAttributes: Output<Either<String, CloudEventAttributeType>>? = null, compression: Output<Either<String, DataflowEndpointKafkaCompression>>? = null, consumerGroupId: Output<String>? = null, copyMqttProperties: Output<Either<String, OperationalMode>>? = null, host: Output<String>, kafkaAcks: Output<Either<String, DataflowEndpointKafkaAcks>>? = null, partitionStrategy: Output<Either<String, DataflowEndpointKafkaPartitionStrategy>>? = null, tls: Output<TlsPropertiesArgs>? = null)