Add possibility to use embedded Kafka broker / producer / simple consumer

Question

Add possibility to use embedded Kafka broker / producer / simple consumer

Closed this issue 11 years ago · 2 comments

It would be very useful for testing.
Example: https://gist.github.com/mardambey/2650743

PS: Maybe I'm wrong and it's impossible to use Kafka without ZooKeeper..

Answer 1 · 2014-04-11T16:05:57.000Z

Hi Vladislav,

Apologies if I'm misunderstanding but we already do this in clj-kafka.test.utils, we create an in-memory broker and ZK cluster for testing the lib. We don't use the embedded broker directly but wire up something very similar- it serves the same purpose.

Answer 2 · 2014-04-12T11:35:26.000Z

Hello Paul,
Sorry for silly question. Yes, it is what I need, thanks!