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