pagerduty / scala-kafka-consumer

An opinionated wrapper around the Kafka consumer for Scala

GitHub
Version Matrix

PagerDuty Kafka Consumer

Build Status

This is an open source project!

This is an opinionated wrapper around the Kafka consumer, adding a default set of policies/interactions. It also specifies the version of the Kafka client library to use as a transitive dependency (so don't double-specify it if you're depending on this library) and provides a base test class for Kafka-eske integration tests.

*** NOTE: This library uses Java 8 functionality. ***

Installation

This library is published as a number of different artifacts to the PagerDuty Bintray OSS Maven repository:

resolvers += "bintray-pagerduty-oss-maven" at "https://dl.bintray.com/pagerduty/oss-maven"

Currently, there are two different consumers available:

  • SimpleKafkaConsumer - As the name suggests, this consumer is very simple to use and has few dependencies. It is available as follows:

    libraryDependencies += "com.pagerduty" %% "kafka-consumer" % "<version>"

  • PartitionedKafkaConsumer - This consumer improves on SimpleKafkaConsumer at the expense of an additional dependency (Akka Streams) and no support for 2.10. This consumer processes and commits Kafka messages for each assigned partition independently and in parallel. Therefore, this consumer is both faster and more tolerant of transient processing failures. It is available as follows:

    libraryDependencies += "com.pagerduty" %% "kafka-consumer-partitioned" % "<version>"

Usage

This library is published as a number of separate artifacts

Create a new SimpleKafkaConsumer or PartitionedKafkaConsumer and get cranking. Usually you need three items to get a default consumer up and running:

  • The topic the consumer works on (constructor argument)
  • The consumer group your consumer belongs to (passed through properties)
  • A bootstrap server to start talking to the Kafka cluster (passed through properties)

For testing, you can re-use/build on the classes in the com.pagerduty.kafkaconsumer.testsupport package, which contains a base Spec to inherit from if you need a Kafka integration test.

Release

Follow these steps to release a new version:

  • Update version.sbt in your PR
  • Update CHANGELOG.md in your PR
  • When the PR is approved, merge it to master, and delete the branch
  • Travis will run all tests, publish to Artifactory, and create a new version tag in Github

Documentation

Markdown Badge

Create badge

×
Markdown:
[![kafka-consumer-test-support Scala version support](https://index.scala-lang.org/pagerduty/scala-kafka-consumer/kafka-consumer-test-support/latest-by-scala-version.svg)](https://index.scala-lang.org/pagerduty/scala-kafka-consumer/kafka-consumer-test-support)
libraryDependencies += "com.pagerduty" %% "kafka-consumer-test-support" % "0.6.2"
resolvers += Resolver.bintrayRepo("pagerduty", "oss-maven")
Ammonite REPL 
import $ivy.`com.pagerduty::kafka-consumer-test-support:0.6.2`
import ammonite._, Resolvers._
val res = Resolver.Http(
  "Bintray pagerduty oss-maven",
  "Some(https://dl.bintray.com/pagerduty/oss-maven)",
  IvyPattern,
  false)
interp.resolvers() = interp.resolvers() :+ res
<dependency>
  <groupId>com.pagerduty</groupId>
  <artifactId>kafka-consumer-test-support_2.12</artifactId>
  <version>0.6.2</version>
</dependency>
compile group: 'com.pagerduty', name: 'kafka-consumer-test-support_2.12', version: '0.6.2'
Mill build tool 
ivy"com.pagerduty::kafka-consumer-test-support:0.6.2"
MavenRepository("https://dl.bintray.com/pagerduty/oss-maven")
Try online with Scastie
Try on Scastie

Statistics

Contributors

License

5 Dependencies

Java Dependency

1 Internal Dependency