search

jpzk / mockedstreams

Scala DSL for Unit-Testing Processing Topologies in Kafka Streams
Apache License 2.0
187 stars 24 forks source link

Support Kafka 2.0 #34

Closed nvladimiroff closed 6 years ago

nvladimiroff commented 6 years ago

Kafka 2.0 has been released and it'd be useful if mockedstreams supported it.

mowczare commented 6 years ago

Also, 1.8.0 version supporting Kafka 1.1.1 has not been pushed to mvn repo.

jpzk commented 6 years ago

@nvladimiroff 2.0.0 changed the API a lot, the ProcessorTopologyTestDriver is not existent anymore. I just had a look the closest might be https://github.com/apache/kafka/blob/trunk/streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java, I'll have a look later @mowczare My apologies I'll check soon!

jpzk commented 6 years ago

@nvladimiroff v2.0 is released @mowczare Thanks for letting me know, it is now in Maven Central