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 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:
    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:
    In above class, I've also added method for publishing and consume from
    Please share your opinion.

Reply via email to