Re: EmbeddedKafka Server for testing kafka related code

2016-10-13 Thread Chinmay Kolhatkar
I can look into possibility of using this in existing tests as well. Basically the idea behind this EmbeddedKafka class is to provide a single object which spawns up JVM-local Kafka Cluster. Possibly there are extensions (like multiple brokers etc) which needs to be done in this class for making

Re: EmbeddedKafka Server for testing kafka related code

2016-10-13 Thread Thomas Weise
+1, how hard is it to change the existing tests in the Kafka module to use it? Different versions are IMO not an issue for the existing tests, they already run against a fixed version (the broker is launched as part of the test). On Thu, Oct 13, 2016 at 9:59 AM, Sanjay Pujare wrote: > Strong +1

Re: EmbeddedKafka Server for testing kafka related code

2016-10-13 Thread Sanjay Pujare
Strong +1 for using embedded kafka. Found embedded servers very useful in ActiveMQ and SQS (ElasticMQ) unit tests. My only question/concern is how well can you simulate different versions of Kafka. On 10/13/16, 7:25 AM, "Chinmay Kolhatkar" wrote: Dear Community, While testing kafk