mguenther/kafka-junit

can we define an embedded connect cluster that connects to an external kakfa cluster?

Closed this issue · 1 comments

In the sequence of #91 I was looking at https://mguenther.github.io/kafka-junit/#section:external-kafka-cluster

But since I use mainly the context of KafkaConnects for my tests this is really not for me.
But I was wondering that it would be cool if we could provide an embbeded Connect cluster that connects to the external cluster, so that I can at least avoid having to deal with the zookeeper that on windows makes my test setup a bit weird.

I can answer my own question indeed it's possible.

something like this should work:

EmbeddedConnect connect = new EmbeddedConnect(connectConfig, this.bootstrapServer, clusterId);

where boostrapserver would come from kakfacontainer/external cluster and the clusterId can be any random string