lujiajing1126/scala-kafka-client

Scala helper modules for operating the Apache Kafka client library (0.9.x - 0.10.x)

Download

Step 1. Add the JitPack repository to your build file

Add it in your root settings.gradle at the end of repositories:

	dependencyResolutionManagement {
		repositoriesMode.set(RepositoriesMode.FAIL_ON_PROJECT_REPOS)
		repositories {
			mavenCentral()
			maven { url 'https://jitpack.io' }
		}
	}

Add it in your settings.gradle.kts at the end of repositories:

	dependencyResolutionManagement {
		repositoriesMode.set(RepositoriesMode.FAIL_ON_PROJECT_REPOS)
		repositories {
			mavenCentral()
			maven { url = uri("https://jitpack.io") }
		}
	}

Add to pom.xml

	<repositories>
		<repository>
		    <id>jitpack.io</id>
		    <url>https://jitpack.io</url>
		</repository>
	</repositories>

Add it in your build.sbt at the end of resolvers:

 
    resolvers += "jitpack" at "https://jitpack.io"

Add it in your project.clj at the end of repositories:

 
    :repositories [["jitpack" "https://jitpack.io"]]

Step 2. Add the dependency

	dependencies {
		implementation 'com.github.lujiajing1126:scala-kafka-client:v0.10.2.1'
	}
	dependencies {
		implementation("com.github.lujiajing1126:scala-kafka-client:v0.10.2.1")
	}
	<dependency>
	    <groupId>com.github.lujiajing1126</groupId>
	    <artifactId>scala-kafka-client</artifactId>
	    <version>v0.10.2.1</version>
	</dependency>

                            
    libraryDependencies += "com.github.lujiajing1126" % "scala-kafka-client" % "v0.10.2.1"
        
        

                            
    :dependencies [[com.github.lujiajing1126/scala-kafka-client "v0.10.2.1"]]

Readme

Scala support for Apache Kafka's Java client library 0.9.0.x and 0.10.x.x

Join the chat at https://gitter.im/cakesolutions/scala-kafka-client Build status Dependencies codecov

This project comprises a few helper modules for operating the Kafka Java Client Driver in a Scala codebase.

<img src="https://raw.githubusercontent.com/wiki/cakesolutions/scala-kafka-client/images/logo.png" align="sck" height="250" width="300">

Status

These modules are production ready, actively maintained and are used in a large scale production system.

Artifact Resolution

To resolve any of the modules, add the following resolver to the build.sbt:

resolvers += Resolver.bintrayRepo("cakesolutions", "maven")

Components

Scala Kafka Client

A thin Scala wrapper over the official Apache Kafka Java Driver. This module is useful for integrating with Kafka for message consumption/delivery, but provides some helpers for convenient configuration of the driver and usage from Scala. Minimal 3rd party dependencies are added in addition to the Kafka client.

For configuration and usage, see the Wiki: Scala Kafka Client Guide

SBT library dependency:

libraryDependencies += "net.cakesolutions" %% "scala-kafka-client" % "0.10.2.1"

Akka Integration

This module provides a configurable asynchronous and non-blocking Kafka Consumer and Producer Actor implementations to support high performance, parallel custom stream processing in an Akka application. These components are specifically intended for use cases where high performance and scalable message processing is required with specific concern for message delivery guarantees and resilience.

For configuration and usage, see the Wiki: Akka Integration

SBT library dependency:

libraryDependencies += "net.cakesolutions" %% "scala-kafka-client-akka" % "0.10.2.1"

TestKit

The TestKit module provides some tools to support integration testing of client service code that depends on a running Kafka Server. Helps the setup of an in-process Kafka and Zookeeper server.

For usage, see the Wiki: TestKit User Guide

SBT library dependency:

libraryDependencies += "net.cakesolutions" %% "scala-kafka-client-testkit" % "0.10.2.1" % "test"

Version Compatibility

Starting after version 0.8.0, the versioning for Scala Kafka client will be tracking Kafka's versioning scheme. Binary compatibility in the new versioning system works as follows:

  • The first and the second digit in the version indicate compatibility with the Kafka driver. For example, 0.9.0.0 is compatible with Kafka 0.9 and 0.10.0.0 is compatible with Kafka 0.10.
  • The third digit in the version indicates an incompatible change between Scala Kafka client versions. For example, 0.9.0.1 is not binary compatible with 0.9.1.0.
  • The fourth digit in the version indicates a compatible change between Scala Kafka client versions. For example, 0.9.0.0 is compatible with 0.9.0.1.

Both the 0.9.* and 0.10.* versions are maintained concurrently.

Here is the full table of binary compatibilities between Scala Kafka client and the Kafka Java driver:

Scala Kafka client | Kafka Java Driver --------------------- | ----------------- 0.10.2.x | 0.10.2.x 0.10.1.x | 0.10.1.x 0.10.0.0 | 0.10.0.x 0.9.0.0 | 0.9.0.x 0.8.0 | 0.10.0.0 0.7.0 | 0.9.0.1

Change log

0.10.2.1 - 05/2017

  • Update Kafka to 0.10.2.1
  • Update Akka to 2.4.18

0.10.2.0 - 02/2017

  • Update Kafka to 0.10.2.0
  • Update dependencies
  • Minor tweaks to logging verbosity

0.10.1.2 - 01/2017

  • Crossbuild for Scala 2.11.8 and 2.12.1
  • Added maxMetaDataAge to KafkaConsumer (thanks @nitendragautam)
  • KafkaConsumerActor now terminates on downstream receiver actor termination (thanks @yoks)
  • Fixed bug related to Exception Handling in KafkaProducer (thanks @conniec)

0.10.1.1 - 11/2016

  • Added new subscription mode: AutoPartitionWithManualOffset.
  • Updated Akka to 2.4.14.
  • Added new Retry count config, to prevent overwhelming an unresponsive downstream client.

0.10.1.0 - 11/2016

  • Supports Kafka 0.10.1.0
  • Added support for new Consumer property: max.poll.interval
  • Removed log4j-over-slf4j dependency
  • Added examples to source

0.9.0.0,0.10.0.0 - 08/2016

  • Subscribe model changed, now supports more explicit subscription types
  • Handling of partition rebalances improved
  • ConsumerActor failure and restart mechanics improved
  • Versioning scheme changed
  • Testkit improvements
  • ConsumerActor wrapper API provided
  • Tested against Kafka 0.10.0.1

0.8.0 - 06/2016

  • Supports Kafka Client 0.10.0.0
  • Add max.poll.records config option to consumer

0.7.0 - 05/2016

  • Supports Kafka Client 0.9.0.1

Acknowledgements

<img src="https://www.yourkit.com/images/yklogo.png" align="right"/>

YourKit supports open source projects with its full-featured Java Profiler. YourKit, LLC is the creator of YourKit Java Profiler and YourKit .NET Profiler, innovative and intelligent tools for profiling Java and .NET applications.

License

Copyright 2016, Cake Solutions.

Licensed under the MIT License