Параметры API для создания тем в Kafka для не-Java языков
Хотя вы можете создать тему через Java или языки на основе Java (см.Вот), кажется, нет чистого способа сделать это без использования Java. В результате, чисто языковые клиентские API (например,kafka-node
, чистый клиент JavaScript) не может напрямую создавать темы. Вместо этого у нас есть два варианта:
1) Используйте хак, например, отправив запрос метаданных в тему - еслиauto.create.topics.enable
установлен вtrue
затем вы можете создать тему - но только с настройками по умолчанию, без контроля над разделами и т. д.
2) Напишите обертку вокруг клиента на основе Java только для создания темы. Самый простой способ сделать этоexec
сценарийbin/kafka-topics.sh
с аргументами командной строки, что некрасиво, если не сказать больше.
Есть ли лучший способ сделать это, хотя? Для Zookeeper есть чистый JavaScript-клиент,node-zookeeper-client
что произойдет, если я манипулирую информацией о брокере / разделе непосредственно в Zookeeper?
Есть еще мысли?