Cómo automatizar las pruebas de Kafka

Luego de consultar expertos en esta materia, programadores de varias áreas y maestros hemos dado con la solución a la interrogande y la plasmamos en esta publicación.

Solución:

Puede iniciar Kafka mediante programación en su prueba de integración, Kafka usa Zookeeper, así que primero mire Zookeeper TestingServer: la instancia de esta clase crea e inicia el servidor Zk usando el puerto dado.

A continuación, mire KafkaServerStartable.scala, debe proporcionar una configuración que apunte a su servidor Zk en memoria e invocar startup() método, aquí hay algo de código:

import kafka.server.KafkaConfig; 
import kafka.server.KafkaServerStartable;
import java.util.Properties;

public KafkaTest() 
    Properties properties = createProperties();
    KafkaConfig kafkaConfig = new KafkaConfig(properties);
    KafkaServerStartable kafka = new KafkaServerStartable(kafkaConfig);
    kafka.startup();

Espero que esto ayude 🙂

Si te ha sido provechoso este artículo, nos gustaría que lo compartas con otros programadores de este modo contrubuyes a dar difusión a nuestro contenido.

---

---

Utiliza Nuestro Buscador