Si bien puede crear un tema a través de Java o lenguajes basados en Java (consulteaquí), no parece haber una forma limpia de hacerlo sin utilizar Java. Como resultado, las API de cliente de lenguaje puro (comokafka-node, un cliente de JavaScript puro) no puede crear temas directamente. En cambio, tenemos dos opciones:

1) Use un truco como enviar una solicitud de metadatos a un tema, siauto.create.topics.enable se establece entrue, puede crear un tema, pero solo con la configuración predeterminada, sin control sobre particiones, etc.

2) Escriba un contenedor alrededor de un cliente basado en Java solo para la creación de temas. La forma más fácil de hacer esto esexec la secuencia de comandosbin/kafka-topics.sh con argumentos de línea de comando, que es feo, por decir lo menos.

Sin embargo, ¿hay una mejor manera de hacer esto? Hay un cliente de JavaScript puro para Zookeeper,node-zookeeper-client, ¿qué sucede si manipulo la información del agente / partición directamente en Zookeeper?

¿Alguna otra idea?