wow-kafka/me.ahoo.wow.kafka/KafkaStateEventBus

KafkaStateEventBus

class KafkaStateEventBus(topicConverter: StateEventTopicConverter, senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer, receiverPolicy: KafkaReceiverPolicy, recordDecodeFailureHandler: KafkaRecordDecodeFailureHandler) : DistributedStateEventBus, AbstractKafkaBus<StateEvent<*>, StateEventExchange<*>>

Constructors

Link copied to clipboard
constructor(topicConverter: StateEventTopicConverter, senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer, receiverPolicy: KafkaReceiverPolicy, recordDecodeFailureHandler: KafkaRecordDecodeFailureHandler)
constructor(topicConverter: StateEventTopicConverter = DefaultStateEventTopicConverter(), senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer = NoOpReceiverOptionsCustomizer)

Properties

Link copied to clipboard
open override val messageType: Class<StateEvent<*>>
Link copied to clipboard
open override val topicKind: TopicKind

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard
open fun receive(subscription: MessageSubscription): Flux<StateEventExchange<*>>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open fun send(message: StateEvent<*>): Mono<Void>
Link copied to clipboard
open override fun StateEvent<*>.toExchange(receiverOffset: ReceiverOffset): StateEventExchange<*>
Generated by Dokka
© 2026 Copyright