Entradas

Ejemplo practico de Kafka con Go, parte 2

Publicar y leer mensajes con Go En la parte uno se vieron conceptos básicos de Kafka y como levantar una instancia local que  será necesario para continuar con este ejemplo práctico usando Go como lenguaje.  Para ello escribiremos los dos programas, ya con nuestro cluster y broker de Kafka corriendo en nuestro equipo, esta parte es la más fácil. El Producer func producer ( ctx context . Context ) { i := 0 // Intialize the writer w := kafka . NewWriter ( kafka . WriterConfig { Brokers : [] string { brokerAddress }, Topic : topic , }) for { // Each kafka message has a key and value. The key is used // to decide which partition (and consequently, which broker) // the message gets published on err := w . WriteMessages ( ctx , kafka . Message { Key : [] byte ( strconv . Itoa ( i )), // Message Value : [] byte ( "message number " + strconv . Itoa ( i )), }) if er