MqttToKafkaRoutesArgsBuilder

Functions

Link copied to clipboard
@JvmName(name = "wcwdftndxlcdulgq")
fun kafkaAcks(value: KafkaAcks)
@JvmName(name = "qrsoejyagtahcdlm")
suspend fun kafkaAcks(value: Either<String, KafkaAcks>)
@JvmName(name = "bgoifbxgrnikqmbe")
suspend fun kafkaAcks(value: Output<Either<String, KafkaAcks>>)
@JvmName(name = "cqddnjpdbjappcgs")
fun kafkaAcks(value: String)
Link copied to clipboard
@JvmName(name = "bngervycxynuvikg")
suspend fun kafkaTopic(value: Output<String>)
@JvmName(name = "ourqhjcgjqtstmwy")
suspend fun kafkaTopic(value: String)
Link copied to clipboard
@JvmName(name = "sfrpywbavjrbgrxj")
suspend fun mqttTopic(value: Output<String>)
@JvmName(name = "ntcrdsvkcbcsocvt")
suspend fun mqttTopic(value: String)
Link copied to clipboard
@JvmName(name = "mmcrrreflacqsjpo")
suspend fun name(value: Output<String>)
@JvmName(name = "khhycoayjptvfjhn")
suspend fun name(value: String)
Link copied to clipboard
@JvmName(name = "xbmchunewjrqceqo")
suspend fun qos(value: Output<Int>)
@JvmName(name = "deofpuvyygkjbxpa")
suspend fun qos(value: Int?)
Link copied to clipboard
@JvmName(name = "iwdqnsnvfwlqixvj")
suspend fun sharedSubscription(value: KafkaSharedSubscriptionPropertiesArgs?)
@JvmName(name = "crjxaphxxsfxbbcu")
suspend fun sharedSubscription(value: Output<KafkaSharedSubscriptionPropertiesArgs>)
@JvmName(name = "jyjrtjcudmbhuitd")
suspend fun sharedSubscription(argument: suspend KafkaSharedSubscriptionPropertiesArgsBuilder.() -> Unit)