NewEventBus creates an EventBus, with optional settings.

WithAutoCreateTopic specifies whether the event bus should automatically create the topic if it does not exist.

WithCodec uses the specified codec for encoding events.

WithStartOffset sets the consumer group's offset to start at Defaults to: LastOffset Per the kafka client documentation StartOffset determines from whence the consumer group should begin consuming when it finds a partition without a committed offset.

WithTopic uses the specified topic for the event bus topic name.

WithTopicPartitions uses the specified number of partitions when creating the event bus topic.

EventBus is a local event bus that delegates handling of published events to all matching registered handlers, in order of registration.

Option is an option setter used to configure creation.