Inicio Explorar Axuda
Rexistro Iniciar sesión
publics
/
sarama
0
0
Fork 0
Ficheiros Incidencias 0 Pull Requests 0 Wiki
Rama: client-interface-private
Ramas Etiquetas
sarama
/
examples
/
consumergroup
Diego Alvarez 7b0711a9ae Adds a Producer Interceptor example %!s(int64=4) %!d(string=hai) anos
..
README.md 7884a5f3f4 feat: consumer group example %!s(int64=5) %!d(string=hai) anos
go.mod 7b0711a9ae Adds a Producer Interceptor example %!s(int64=4) %!d(string=hai) anos
go.sum 7b0711a9ae Adds a Producer Interceptor example %!s(int64=4) %!d(string=hai) anos
main.go 31886822ab Fix typos %!s(int64=4) %!d(string=hai) anos

README.md

Consumergroup example

This example shows you how to use the Sarama consumer group consumer. The example simply starts consuming the given Kafka topics and logs the consumed messages.

$ go run main.go -brokers="127.0.0.1:9092" -topics="sarama" -group="example"