package Ġkafka . flow . consumer Ċ Ċ import Ġkafka . flow . server . Kafka Server Ċ import Ġorg . test containers . containers . Kafka Container Ċ import Ġorg . test containers . utility . Docker Image Name Ċ Ċ object ĠTest Kafka Server Ġ{ ĊĠĠĠ Ġprivate Ġval Ġkafka Container : ĠKafka Container Ġ= ĠKafka Container ( Docker Image Name . parse (" con fluent inc / cp - kafka : 6 . 2 . 0 ")) ĊĠĠĠ Ġlateinit Ġvar Ġkafka Server : ĠKafka Server ĊĊĠĠĠ Ġfun Ġstart () Ġ{ ĊĠĠĠĠĠĠĠ Ġkafka Container . start () ĊĠĠĠĠĠĠĠ Ġkafka Server Ġ= ĠKafka Server ( kafka Container . bootstrap Servers ) ĊĠĠĠ Ġ} Ċ }