Eco Commons Kafka

It's a library of utilities, helpers and higher-level APIs for the Kafka client library.

The currently supported version is 3.0.0

The library can be obtained from the Maven by adding the following dependency in the pom.xml:

<dependency>
    <groupId>com.epam.eco</groupId>
    <artifactId>commons-kafka</artifactId>
    <version>${project.version}</version>
</dependency>

Features

Advanced consumer to handle long-running tasks
Bootstrap consumer to all records from topic
Helpers to perform various common tasks (for example count records in topic)
In-memory caches
Common implementations of Serializer/Deserializer
Jackson module for serializing/deserializing Kafka types
Configuration builders

Build

git clone git@github.com:epam/eco-commons-kafka.git
cd eco-commons-kafka
mvn clean package

Compatibility matrix

Eco Commons Kafka	Kafka	Scala
2.0.x	3.0.x	13
1.8.x	2.8.x	12
1.7.x	2.7.x	12
1.6.x	2.6.x	12
1.5.x	2.5.x	12
1.4.x	2.4.x	12
1.3.x	2.3.x	12
1.2.x	2.2.x	12
1.1.x	2.1.x	12
1.0.x	2.0.x	12
0.1.x	1.0.x	11

License

Licensed under the Apache License, Version 2.0