scalatest-embedded-kafka
scalatest-embedded-kafka copied to clipboard
manub
A library that provides an in-memory Kafka instance to run your tests against.
Hi ManuB, I included scalatest-embedded-kafka in the test scope in my project. but when I compile the code it gives the following errors. > [info] [SUCCESSFUL ] net.manub#scalatest-embedded-kafka_2.11;0.11.1!scalatest-embedded-kafka_2.11.jar (2546ms) [warn]...
Hi, I'm using your tool to make some unit test on Kafka. I wrote a test in which I want to assert that if I restart Kafka, a consumer with...
Please could you enable running multiple brokers? Testing with the *exactly once guarantee* turned on requires at least `3` brokers: ```scala p.put(StreamsConfig.PROCESSING_GUARANTEE_CONFIG, StreamsConfig.EXACTLY_ONCE) ``` Associated errors: ``` ERROR KafkaApis:99 -...
Hi I am using this code to test that my Kafka Producer is correctly writing to kafka describe("publish message to kafka topic") { it("should publish the message to kafka topic")...
Firstly, thanks for developing such a nice tool very useful for Kafka development. I'm using the `withRunningKafka` method to test publishing to an embedded Kafka instance using `ReactiveKafka`. ```Scala "KafkaEvnetSink"...
When I create a stream using the Spark 010 API, I see messages posted to all topics. When I create a kafka consumer using the 010 spark streams API I...
Hi, not sure this is tied to the library or somehow to the client used for tests. Our test suites fail quite regularly if we configure timeouts for our kafka...
`request.max.timeout.ms` is set too high, and should be probably lowered for the underlying consumer (even if the problem only appears in a non-likely use case, when trying to consume from...
