wow-kafka/me.ahoo.wow.kafka

Package-level declarations

Types

abstract class AbstractKafkaBus<M : Message<*, *>, AggregateIdCapable, NamedAggregate, E : MessageExchange<*, M>>(topicConverter: AggregateTopicConverter, senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer, receiverPolicy: KafkaReceiverPolicy, recordDecodeFailureHandler: KafkaRecordDecodeFailureHandler) : DistributedMessageBus<M, E>

AcknowledgeKafkaRecordDecodeFailureHandler

object AcknowledgeKafkaRecordDecodeFailureHandler : KafkaRecordDecodeFailureHandler

AggregateTopicConverter

fun interface AggregateTopicConverter

CommandTopicConverter

interface CommandTopicConverter : AggregateTopicConverter

DefaultCommandTopicConverter

class DefaultCommandTopicConverter(topicPrefix: String = Wow.WOW_PREFIX) : CommandTopicConverter

DefaultEventStreamTopicConverter

class DefaultEventStreamTopicConverter(topicPrefix: String = Wow.WOW_PREFIX) : EventStreamTopicConverter

DefaultStateEventTopicConverter

class DefaultStateEventTopicConverter(topicPrefix: String = Wow.WOW_PREFIX) : StateEventTopicConverter

EventStreamTopicConverter

interface EventStreamTopicConverter : AggregateTopicConverter

FailKafkaRecordDecodeFailureHandler

object FailKafkaRecordDecodeFailureHandler : KafkaRecordDecodeFailureHandler

KafkaCommandBus

class KafkaCommandBus(topicConverter: CommandTopicConverter, senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer, receiverPolicy: KafkaReceiverPolicy, recordDecodeFailureHandler: KafkaRecordDecodeFailureHandler) : DistributedCommandBus, AbstractKafkaBus<CommandMessage<*>, ServerCommandExchange<*>>

KafkaDomainEventBus

class KafkaDomainEventBus(topicConverter: EventStreamTopicConverter, senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer, receiverPolicy: KafkaReceiverPolicy, recordDecodeFailureHandler: KafkaRecordDecodeFailureHandler) : DistributedDomainEventBus, AbstractKafkaBus<DomainEventStream, EventStreamExchange>

KafkaEventStreamExchange

data class KafkaEventStreamExchange(val message: DomainEventStream, receiverOffset: ReceiverOffset, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : EventStreamExchange

KafkaReceiverPolicy

class KafkaReceiverPolicy(val prefetchBatches: Int = DEFAULT_PREFETCH_BATCHES, val maxDeferredCommits: Int = DEFAULT_MAX_DEFERRED_COMMITS, val retrySpec: Retry = defaultRetrySpec())

KafkaRecordDecodeException

class KafkaRecordDecodeException(failure: KafkaRecordDecodeFailure) : RuntimeException

KafkaRecordDecodeFailure

data class KafkaRecordDecodeFailure(val record: ReceiverRecord<String, String>, val cause: Exception)

KafkaRecordDecodeFailureHandler

fun interface KafkaRecordDecodeFailureHandler

KafkaServerCommandExchange

class KafkaServerCommandExchange<C : Any>(val message: CommandMessage<C>, receiverOffset: ReceiverOffset, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : ServerCommandExchange<C>

KafkaStateEventBus

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

KafkaStateEventExchange

class KafkaStateEventExchange<S : Any>(val message: StateEvent<S>, receiverOffset: ReceiverOffset, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : StateEventExchange<S>

NoOpReceiverOptionsCustomizer

object NoOpReceiverOptionsCustomizer : ReceiverOptionsCustomizer

ReceiverOptionsCustomizer

fun interface ReceiverOptionsCustomizer

StateEventTopicConverter

interface StateEventTopicConverter : AggregateTopicConverter

Functions

getReceiverOptionsCustomizer

fun ContextView.getReceiverOptionsCustomizer(): ReceiverOptionsCustomizer?

writeReceiverOptionsCustomizer

fun Context.writeReceiverOptionsCustomizer(receiverOptionsCustomizer: ReceiverOptionsCustomizer): Context