scalatest-embedded-kafka
scalatest-embedded-kafka copied to clipboard
manub
A library that provides an in-memory Kafka instance to run your tests against.
A release for 2.13.0-M3 would be great as a first step before releasing for 2.13.0-M4 which has new scala collections.
I started working PRs for #109 and #92 but have run into a problem running tests. I'm posting here in hopes of getting some help in resolving the issue. So...
I couldn't add the 2.13 target because kafka itself has no binary yet. I figured this out later when I already upgraded the other dependencies. Maybe this is still useful...
I want to test if an offset is committed or not (because only commit in some situations). I have not found any way to test that. I'm very newbie at...
Using `"net.manub" %% "scalatest-embedded-kafka" % "1.1.1"` I'm seeing an issue with stopping the embedded servers if the servers have been started individually. When I start the servers by calling `start()`...
Hello, I am using `runStreams` in my [tests](https://github.com/jacobBaumbach/kafka-stream-session-example/blob/master/src/test/scala/exampleSpec.scala) to see whether my KTable is accurately tracking a user session. I am printing the results of my KTable and I am...
I am running tests over the same Kafka Streams topology. I have different suites extending EmbeddedKafkaStreamsAllInOne. Each suite uses different ZK and Kafka ports, application name and topic names (same...
I recently wrote #143 and #144 to address some needs I had for running embedded Kafka in TestNG+Java tests. As it turns out, I actually need to run embedded Kafka...
Hello, I'm trying to use the version 0.9.0 because I'm using Spark Streaming 2.0.2 and it seems the most compatible version. But this version has some bugs (Java heap problem...)...
