You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: README.md
+4-2Lines changed: 4 additions & 2 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -21,10 +21,12 @@ scalatest-embedded-kafka is available on Bintray and Maven Central, compiled for
21
21
* Scala 2.12 is supported from `0.11.0`.
22
22
23
23
Versions match the version of Kafka they're built against.
24
+
25
+
*If you're using Kafka 1.1.0, please use version `1.1.0-kafka-1.1`*
24
26
25
27
### How to use
26
28
27
-
* In your `build.sbt` file add the following dependency: `"net.manub" %% "scalatest-embedded-kafka" % "1.1.0" % "test"`
29
+
* In your `build.sbt` file add the following dependency: `"net.manub" %% "scalatest-embedded-kafka" % "1.1.0-kafka1.1" % "test"`
28
30
* Have your `Spec` extend the `EmbeddedKafka` trait.
29
31
* Enclose the code that needs a running instance of Kafka within the `withRunningKafka` closure.
30
32
@@ -229,7 +231,7 @@ It takes care of instantiating and starting your streams as well as closing them
229
231
230
232
### How to use
231
233
232
-
* In your `build.sbt` file add the following dependency: `"net.manub" %% "scalatest-embedded-kafka-streams" % "1.1.0" % "test"`
234
+
* In your `build.sbt` file add the following dependency: `"net.manub" %% "scalatest-embedded-kafka-streams" % "1.1.0-kafka1.1" % "test"`
233
235
* Have a look at the [example test](kafka-streams/src/test/scala/net/manub/embeddedkafka/streams/ExampleKafkaStreamsSpec.scala)
234
236
* For most of the cases have your `Spec` extend the `EmbeddedKafkaStreamsAllInOne` trait. This offers both streams management and easy creation of consumers for asserting resulting messages in output/sink topics.
235
237
* If you only want to use the streams management without the test consumers just have the `Spec` extend the `EmbeddedKafkaStreams` trait.
0 commit comments