KafkaCommandBus

class KafkaCommandBus(topicConverter: CommandTopicConverter = DefaultCommandTopicConverter(), senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer = NoOpReceiverOptionsCustomizer) : AbstractKafkaBus<CommandMessage<*>, ServerCommandExchange<*>> , DistributedCommandBus

Constructors

constructor(topicConverter: CommandTopicConverter = DefaultCommandTopicConverter(), senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer = NoOpReceiverOptionsCustomizer)

open override val topicKind: TopicKind

open override fun close()

abstract fun send(message: CommandMessage<*>): Mono<Void>

open override fun CommandMessage<*>.toExchange(receiverOffset: ReceiverOffset): ServerCommandExchange<*>