@@ -47,15 +47,16 @@ class KafkaController(
4747 kafkaExternalHostPort : Int ,
4848 createTopics : Seq [String ]
4949) extends DockerControllerImpl (dockerClient, outputFrameInterval)(imageName, imageTag) {
50- val networkId : String = dockerClient.createNetworkCmd().withName(" kafka-" + UUID .randomUUID().toString).exec().getId
50+ lazy val networkId : String =
51+ dockerClient.createNetworkCmd().withName(" kafka-" + UUID .randomUUID().toString).exec().getId
5152
52- val kafkaNetwork : Network = Network (networkId)
53- val zkAlias : NetworkAlias = NetworkAlias (kafkaNetwork, " zk1-" + UUID .randomUUID().toString)
54- val kafkaAlias : NetworkAlias = NetworkAlias (kafkaNetwork, " kafka1-" + UUID .randomUUID().toString)
53+ lazy val kafkaNetwork : Network = Network (networkId)
54+ lazy val zkAlias : NetworkAlias = NetworkAlias (kafkaNetwork, " zk1-" + UUID .randomUUID().toString)
55+ lazy val kafkaAlias : NetworkAlias = NetworkAlias (kafkaNetwork, " kafka1-" + UUID .randomUUID().toString)
5556
56- val zooKeeperHostPort : Int = RandomPortUtil .temporaryServerPort()
57+ lazy val zooKeeperHostPort : Int = RandomPortUtil .temporaryServerPort()
5758
58- val zooKeeperController : ZooKeeperController = ZooKeeperController (dockerClient)(
59+ lazy val zooKeeperController : ZooKeeperController = ZooKeeperController (dockerClient)(
5960 myId = 1 ,
6061 hostPort = zooKeeperHostPort,
6162 containerPort = zooKeeperHostPort, // ZooKeeperController.DefaultZooPort,
@@ -65,11 +66,11 @@ class KafkaController(
6566 protected val zooKeeperWaitPredicate : WaitPredicate =
6667 WaitPredicates .forLogMessageByRegex(ZooKeeperController .RegexForWaitPredicate )
6768
68- private val kafkaContainerName = kafkaAlias.name
69- private val zooKeeperContainerName = zkAlias.name
70- private val zooKeeperContainerPort = zooKeeperController.containerPort
69+ private lazy val kafkaContainerName = kafkaAlias.name
70+ private lazy val zooKeeperContainerName = zkAlias.name
71+ private lazy val zooKeeperContainerPort = zooKeeperController.containerPort
7172
72- private val environmentVariables = Map (
73+ private lazy val environmentVariables = Map (
7374 " KAFKA_AUTO_CREATE_TOPICS_ENABLE" -> (if (createTopics.isEmpty) " false" else " true" ),
7475 " KAFKA_CREATE_TOPICS" -> createTopics.mkString(" ," ),
7576 " KAFKA_BROKER_ID" -> " 1" ,
0 commit comments