wow-kafka/me.ahoo.wow.kafka

Package-level declarations

Types

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

KafkaCommandBus

class KafkaCommandBus(transport: Transport, topicConverter: CommandTopicConverter = DefaultCommandTopicConverter(), decodeFailureHandler: TransportDecodeFailureHandler = TransportDecodeFailureHandler.FAIL) : TransportCommandBus

The command bus on Kafka: a TransportCommandBus over a KafkaTransport, with topics from topicConverter.

KafkaDomainEventBus

class KafkaDomainEventBus(transport: Transport, topicConverter: EventStreamTopicConverter = DefaultEventStreamTopicConverter(), decodeFailureHandler: TransportDecodeFailureHandler = TransportDecodeFailureHandler.FAIL) : TransportDomainEventBus

The domain event stream bus on Kafka: a TransportDomainEventBus over a KafkaTransport, with topics from topicConverter.

KafkaReceiverPolicy

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

Receive-side policy of the Kafka buses.

KafkaRecoverableExceptionProvider

class KafkaRecoverableExceptionProvider : RecoverableExceptionProvider

Registers Kafka's RetriableException (and so each subclass: timeouts, leader changes, unavailable brokers and coordinators, ...) as RecoverableType.RECOVERABLE, so the framework's retries (RetryableFilter, the event-store append resolution) retry a send that failed on a transient broker condition.

KafkaStateEventBus

class KafkaStateEventBus(transport: Transport, topicConverter: StateEventTopicConverter = DefaultStateEventTopicConverter(), decodeFailureHandler: TransportDecodeFailureHandler = TransportDecodeFailureHandler.FAIL) : TransportStateEventBus

The state event bus on Kafka: a TransportStateEventBus over a KafkaTransport, with topics from topicConverter.

KafkaTransport

@WowSpi

open class KafkaTransport(senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer = NoOpReceiverOptionsCustomizer, receiverPolicy: KafkaReceiverPolicy = KafkaReceiverPolicy(), failurePolicy: TransportFailurePolicy = TransportFailurePolicy.DEFAULT) : Transport

Kafka as a Transport: one producer per transport, one consumer per open.

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