Quiero crear un tema en Kafka (kafka_2.8.0-0.8.1.1) a través de java. Funciona bien si creo un tema en el símbolo del sistema y si envío un mensaje a través de la API de Java. Pero quiero crear un tema a través de Java API. Después de una larga búsqueda que encontré debajo del código,

ZkClient zkClient = new ZkClient("localhost:2181", 10000, 10000);
AdminUtils.createTopic(zkClient, myTopic, 10, 1, new Properties());

Intenté el código anterior y muestra que el tema se creó, pero no puedo insertar el mensaje en el tema. ¿Algo mal en mi código? ¿O alguna otra forma de lograr lo anterior?