Kafka

The Kafka extension provides support for Kafka, implementing CommandBus, DomainEventBus, and StateEventBus.

Installation

Gradle(Kotlin)

implementation("me.ahoo.wow:wow-kafka")

Gradle(Groovy)

implementation 'me.ahoo.wow:wow-kafka'

Maven

<dependency>
    <groupId>me.ahoo.wow</groupId>
    <artifactId>wow-kafka</artifactId>
    <version>${wow.version}</version>
</dependency>

Configuration

• Configuration class: KafkaProperties
• Prefix: wow.kafka.

Name	Data Type	Description	Default Value
enabled	Boolean	Whether to enable	true
bootstrap-servers	List<String>	Kafka server addresses
topic-prefix	String	Topic prefix	wow.
properties	Map<String, String>	Common configuration
producer	Map<String, String>	Producer configuration
consumer	Map<String, String>	Consumer configuration

YAML Configuration Example

wow:
  command:
    bus:
      type: kafka
  kafka:
    bootstrap-servers: localhost:61530
    topic-prefix: 'wow.'