kafkaclient

kafkaclient

Golang kafka package to simplify te consumer and producer usage

Install

go get github.com/glean-go/kafkaclient

Consumer

func onMessageReceived(topic string, message string){
  // do stuff with message
}


// listen to test topic
client := kafkaclient.New("localhost:9092", "group1", onMessageReceived)
go client.ListenToTopic(context.Background(), "test")

Producer

client := kafkaclient.New("localhost:9092", "producerGroup", nil)

// produce message to test topic
err := client.ProduceToTopic("test", "this is a test message")

if err != nil {
  // handle error...
}