mockedstreams
mockedstreams copied to clipboard
jpzk
Scala DSL for Unit-Testing Processing Topologies in Kafka Streams
If you pass in the classOf the log and continue exception handler, the mocked streams fails because it can't cast this to a string. KafkaStreams takes care of this internally....
Because we aren't considering that the topology could fail, we're not cleaning up if there is a failure in running the topology. Consider closing even if there was an exception...
When Kafka builds a local table, it often takes some time to stream all of the records in. This means that doing a join against this table may fail due...
I have two streams for inner join: Stream1 : Seq(("key1", 1), ("key3", 1), ("key2", 2)) Stream2: Seq(("key1", 3), ("key2", 1), ("key2", 2)) Expected Stream after inner-join (with addition as result)...
Hello there. I write an kStream consumer (connector). So I don't need the builder's output here. Just run it like `KafkaStreams.start()` does. Can it be added? Something simple, just like...
Hi, thanks for the great library! One problem I encountered was when I tried to test a TumblingWindow aggregation. Let's say I create a 2 second tumbling window like so:...
`MockedStreams.output` doesn't allow you to specify zero for the `size` of the expected output. That means you can't set an expectation that certain inputs should not have any outputs in...
