package Ġdev . vas as . k af kas uite . demo Ċ Ċ import Ġdev . vas as . k af kas uite . cluster . create Docker Kafka Cluster Ċ import Ġdev . vas as . k af kas uite . tools . create Topic Ċ Ċ fun Ġmain () Ġ{ ĊĠĠĠ Ġval Ġkafka Cluster Ġ= Ġcreate Docker Kafka Cluster ( 3 ) ĊĠĠĠ Ġkafka Cluster . start () ĊĠĠĠ Ġkafka Cluster . create Topic ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġtopic Name Ġ= Ġ" my topic ", ĊĠĠĠĠĠĠĠĠĠĠĠ Ġnum Partitions Ġ= Ġ 1 , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreplication Factor Ġ= Ġ 3 , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġmin In Sync Replicas Ġ= Ġ 3 ĊĠĠĠ Ġ) ĊĊĠĠĠ ĠThread . sleep ( Long . MAX _ VALUE ) Ċ } Ċ