Kafka: La Guía Definitiva, 2ª Edición

Capítulo 5. Gestión programática de Apache Kafka

Este trabajo se ha traducido utilizando IA. Agradecemos tus opiniones y comentarios: [e-mail]

Existen muchas herramientas CLI y GUI para gestionar Kafka (hablaremos de ellas en el Capítulo 9), pero también hay ocasiones en las que quieres ejecutar algunos comandos administrativos desde tu aplicación cliente. Un caso de uso especialmente común es la creación de nuevos temas bajo demanda basados en datos o entradas del usuario: Las aplicaciones del Internet de las Cosas (IoT) a menudo reciben eventos de los dispositivos de los usuarios, y escriben eventos en temas basados en el tipo de dispositivo. Si el fabricante produce un nuevo tipo de dispositivo, o bien tienes que acordarte, mediante algún proceso, de crear también un tema, o bien la aplicación puede crear dinámicamente un nuevo tema si recibe eventos con un tipo de dispositivo no reconocido. La segunda alternativa tiene desventajas, pero evitar la dependencia de un proceso adicional para generar temas es una característica atractiva en los escenarios adecuados.

Apache Kafka añadió el AdminClient en la versión 0.11 para proporcionar una API programática para la funcionalidad administrativa que antes se hacía en la línea de comandos: listar, crear y borrar temas; describir el clúster; gestionar ACLs; y modificar la configuración.

He aquí un ejemplo. Tu aplicación va a producir eventos para un tema concreto. Esto significa que antes de producir el primer ...