JarCastingembedded-kafka-schema-registry
A library that provides in-memory instances of both Kafka and Confluent Schema Registry to run your tests against.
Relies on the embedded-kafka library.
Version compatibility matrix
embedded-kafka-schema-registry is available on Maven Central, compiled for Scala 2.12 and 2.13.
Support for Scala 2.11 was dropped by Apache in Kafka v2.5.0.
Versions match the version of Confluent Schema Registry they're built against.
embedded-kafka-schema-registry
How to use
- In your
build.sbtfile add the following resolvers:
resolvers ++= Seq(
"confluent" at "https://packages.confluent.io/maven/",
"jitpack" at "https://jitpack.io"
)
- In your
build.sbtfile add the following dependency (replacex.x.xwith the appropriate version):"io.github.embeddedkafka" %% "embedded-kafka-schema-registry" % "x.x.x" % Test - Have your class extend the
EmbeddedKafkatrait (from thenet.manub.embeddedkafka.schemaregistrypackage). - Enclose the code that needs a running instance of Kafka within the
withRunningKafkaclosure. - Provide an implicit
EmbeddedKafkaConfigImpl(from the same package mentioned before).
class MySpec extends AnyWordSpecLike with Matchers with EmbeddedKafka {
"runs with embedded kafka and Schema Registry" should {
"work" in {
implicit val config = EmbeddedKafkaConfig()
withRunningKafka {
// ... code goes here
}
}
}
}
- In-memory Zookeeper, Kafka, and Schema Registry will be instantiated respectively on port 6000, 6001, and 6002 and automatically shutdown at the end of the test.
embedded-kafka-schema-registry-streams
A library that builds on top of embedded-kafka-schema-registry to offer easy testing of Kafka Streams with Confluent Schema Registry.
It takes care of instantiating and starting your streams as well as closing them after running your test-case code.
How to use
- In your
build.sbtfile add the following dependency (replacex.x.xwith the appropriate version):"io.github.embeddedkafka" %% "embedded-kafka-schema-registry-streams" % "x.x.x" % Test - For most of the cases have your class extend the
EmbeddedKafkaStreamstrait (from thenet.manub.embeddedkafka.schemaregistry.streamspackage). This offers both streams management and easy creation of consumers for asserting resulting messages in output/sink topics. - Use
EmbeddedKafkaStreams.runStreamsandEmbeddedKafka.withConsumerandEmbeddedKafka.withProducer. This allows you to create your own consumers of custom types as seen in the example test.
