Event Store Kafka

CDI extension for Java EE 8 application using Apache Kafka as Event Store

License	The Apache License, Version 2.0
Categories	Net
GroupId	net.osomahe
ArtifactId	eventstore-kafka
Last Version	0.4.4
Release Date	Dec 15, 2019
Type	jar
Description	Event Store Kafka CDI extension for Java EE 8 application using Apache Kafka as Event Store
Project URL	https://github.com/tonda100/eventstore-kafka
Source Code Management	https://github.com/tonda100/eventstore-kafka

Download eventstore-kafka

Filename	Size
eventstore-kafka-0.4.4.pom
eventstore-kafka-0.4.4.jar	29 KB
eventstore-kafka-0.4.4-sources.jar	21 KB
eventstore-kafka-0.4.4-javadoc.jar	150 KB

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/net.osomahe/eventstore-kafka/ -->
<dependency>
    <groupId>net.osomahe</groupId>
    <artifactId>eventstore-kafka</artifactId>
    <version>0.4.4</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/net.osomahe/eventstore-kafka/
implementation 'net.osomahe:eventstore-kafka:0.4.4'

Gradle Kotlin

// https://jarcasting.com/artifacts/net.osomahe/eventstore-kafka/
implementation ("net.osomahe:eventstore-kafka:0.4.4")

Apache Buildr

'net.osomahe:eventstore-kafka:jar:0.4.4'

Apache Ivy

<dependency org="net.osomahe" name="eventstore-kafka" rev="0.4.4">
  <artifact name="eventstore-kafka" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='net.osomahe', module='eventstore-kafka', version='0.4.4')
)

Scala SBT

libraryDependencies += "net.osomahe" % "eventstore-kafka" % "0.4.4"

Leiningen

[net.osomahe/eventstore-kafka "0.4.4"]

Dependencies

compile (1)

Group / Artifact	Type	Version
org.apache.kafka : kafka-clients	jar	2.4.0

provided (1)

Group / Artifact	Type	Version
javax : javaee-api	jar	8.0

test (1)

Group / Artifact	Type	Version
junit : junit	jar	4.12

Project Modules

There are no modules declared in this project.

Event Store Kafka

CDI extension for Java EE 8 application using Apache Kafka as Event Store.

Five minute start

How to quickly start using the Event Store Kafka with your Java EE 8 project.

Setup

1. Add maven dependencies to your pom.xml

   <dependency>
       <groupId>net.osomahe</groupId>
       <artifactId>eventstore-kafka</artifactId>
       <version>0.4.3</version>
   </dependency>

2. Added extensions src/main/resources/META-INF/services/javax.enterprise.inject.spi.Extension

   net.osomahe.esk.EventStoreExtension
   

Producing events

1. Extend AbstractEvent class
2. Use EventStorePublisher#publish(event) method for publishing event to Apache Kafka synchronously. or
3. Use EventStorePublisher#publishAsync(event) method for publishing event to Apache Kafka asynchronously.

Consuming events

1. Extend AbstractEvent class or use the same as for publishing.
2. Observes for CDI event

   public void handleCreate(@Observes TodoCreatedEvent event) {
       // do some magic with event
   }

Advanced

Configuration possibilities and default values. Unfortunately JavaEE 8 does not have any standard means of configuration and I didn't want to

Configuration

Unfortunately JavaEE 8 does not provide any standard way. There are two ways of configuring the eventstore-kafka.

1. Application has to produce using @Produces and correct qualifier see example:

• java.util.Properties with qualifiers @KafkaProducerConfig for overriding producer properties otherwise default values will be in place.

  Properties props = new Properties();
  props.put(BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
  props.put(ACKS_CONFIG, "all");

• java.util.Properties with qualifiers @KafkaConsumerConfig for overriding consumer properties otherwise default values will be in place.

  Properties props = new Properties();
  props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
  props.put(GROUP_ID_CONFIG, "client-application");
  props.put(AUTO_OFFSET_RESET_CONFIG, "earliest");

2. Application has to implement EventStorePublisherConfig and (or) EventStoreConsumerConfig to provide non-default properties

Customization

• @TopicName annotation for an event class to set different topic for given event(s)
• @EventName annotation for an event class to set different event name
• @AsyncEvent annotation for an event class to set asynchronous processing of events @ObeservesAsync required for handling async events

Versions

Version
0.4.4 Dec 15, 2019
0.4.3 Aug 4, 2019
0.4.2 Aug 26, 2018
0.4.1 Jul 29, 2018
0.4.0 Jul 29, 2018
0.3.0 Mar 21, 2018
0.2.0 Feb 11, 2018
0.1.0 Feb 7, 2018