Go

The fluvio-go client is a community project put together by @avinassh.

It’s still under development but still very exciting!

 

Connecting

To connect to the fluvio cluster do:

f, err := fluvio.Connect()
 

Producer

To create a TopicProducer do:

producer, err := f.TopicProducer("hello-go")
 

Sending

To send into a topic do:

val := fmt.Sprintf("(from Go) %d (%s)", i, time.Now().String())
err = producer.SendString(fmt.Sprintf("%d", i), val)