+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 <san...@datatorrent.com>
wrote:

> 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" <chin...@apache.org> wrote:
>
>     Dear Community,
>
>     While testing kafka related endpoint code for Apex-Calcite
> integration, I
>     found an interesting embedded kafka implementation over the internet
> and I
>     used it in my code.
>
>     The implementation is based on ready to use EmbeddedZookeer and
> KafkaServer
>     from mvn dependency kafka_2.11:0.9.0.0:test.
>
>     I found this local kafka server very stable for testing purpose. Would
> it
>     be a good addition to malhar-kafka module in test folder?
>
>     The EmbeddedKafka server is here:
>     https://github.com/chinmaykolhatkar/apex-malhar/
> blob/calcite/sql/src/test/java/org/apache/apex/malhar/
> sql/EmbeddedKafka.java
>
>     In above class, I've also added method for publishing and consume from
>     topic.
>
>     Please share your opinion.
>
>     Thanks,
>     Chinmay.
>
>
>
>

Reply via email to