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 en Apache Kafka con particiones usando Node.js

Crear un tópico en Apache Kafka con particiones usando Node.js - Tutorial de Kafka

Del curso: Domina Apache Kafka

Crear un tópico en Apache Kafka con particiones usando Node.js

Nos han asignado la tarea de crear nuevos tópicos en Kafka, pero con particiones. ¿Particiones? ¿Pero qué es eso? Bueno, te comento que cada tópico en Kafka se puede dividir en una o más particiones, lo que le permite a Kafka manejar grandes flujos de datos a una alta velocidad al dividir los tópicos en partes más pequeñas y manejables. Eso favorece también a un procesamiento paralelo cuando se tienen muchos clientes. Ahora, ¿cómo lo implementamos? Bueno, tenemos una instancia de KafkaClient y tenemos el tópico a crear. Vamos a utilizar el método createTopics. Le pasamos como primer argumento el tópico a crear. Pero ¿dónde le indicamos el número de particiones? Bueno, eso se lo indicamos aquí, en el arreglo de objetos. Vamos a ponerle que el número de particiones son 5 y como replicationFactor, 1. El replicationFactor nos sirve para especificar la cantidad de réplicas que deben mantenerse por cada partición en el tópico. Muy bien, continuemos ahora; en caso de que nos dé un error…

Contenido