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