MqttToKafkaRoutesArgs

data class MqttToKafkaRoutesArgs(val kafkaAcks: Output<Either<String, KafkaAcks>>, val kafkaTopic: Output<String>, val mqttTopic: Output<String>, val name: Output<String>, val qos: Output<Int>? = null, val sharedSubscription: Output<KafkaSharedSubscriptionPropertiesArgs>? = null) : ConvertibleToJava<MqttToKafkaRoutesArgs>

Mqtt to Kafka route properties

Constructors

Link copied to clipboard
constructor(kafkaAcks: Output<Either<String, KafkaAcks>>, kafkaTopic: Output<String>, mqttTopic: Output<String>, name: Output<String>, qos: Output<Int>? = null, sharedSubscription: Output<KafkaSharedSubscriptionPropertiesArgs>? = null)

Properties

Link copied to clipboard
val kafkaAcks: Output<Either<String, KafkaAcks>>

The kafka acks to use.

Link copied to clipboard
val kafkaTopic: Output<String>

The kafka topic to publish to.

Link copied to clipboard
val mqttTopic: Output<String>

The mqtt topic to pull from.

Link copied to clipboard
val name: Output<String>

The name of the route.

Link copied to clipboard
val qos: Output<Int>? = null

The qos to use for mqtt.

Link copied to clipboard

The properties for shared subscription.

Functions

Link copied to clipboard
open override fun toJava(): MqttToKafkaRoutesArgs