Del curso: Domina Apache Kafka

Accede al curso completo hoy mismo

Únete hoy para acceder a más de 24.600 cursos impartidos por expertos del sector.

Crear un tópico de Apache Kafka usando Python

Crear un tópico de Apache Kafka usando Python - Tutorial de Kafka

Del curso: Domina Apache Kafka

Crear un tópico de Apache Kafka usando Python

Los temas o tópicos en Apache Kafka representan una categoría en la que los productores publican los mensajes y desde el cual los consumidores, valga la redundancia, consumen los mensajes. Veamos cómo podemos crear un tópico en Apache Kafka por medio de Python. Importamos KafkaAdminClient y NewTopic de kafka.admin. Lo primero que vamos a hacer es conectarnos a Kafka. Luego, creamos el tópico. Para eso, utilizamos el método NewTopic, donde le indicamos el nombre del tópico, el número de particiones, las cuales permiten escalabilidad y procesamiento paralelo, y replication_factor, que sirve para especificar la cantidad de réplicas que deben mantenerse para cada partición en el tópico. Y luego utilizamos el método create_topics. Le enviamos el tópico que vamos a crear. Ahora pasamos a probar nuestro código. Ejecutamos. Vamos a ir a Kafdrop, vamos a refrescar y aquí vemos que se creó correctamente el tópico. Kafdrop es una herramienta visual para Apache Kafka, en caso de que no la…

Contenido