Go binding for Fluvio streaming platform
Make sure you have already installed fluvio, it is up and running.
# assuming all the dependencies are installed
git clone github.com/avinassh/fluvio-go/fluvio.git
make buildSee the example file for the complete usage.
package main
import "github.com/avinassh/fluvio-go/fluvio"
func main() {
// error handling is omitted for brevity
fluvioClient, _ := fluvio.Connect()
defer fluvioClient.Close()
topicProducer, _ := fluvioClient.TopicProducer("echo")
defer topicProducer.Close()
topicProducer.Send([]byte("0"), []byte("Hello"))
}package main
import "fmt"
import "github.com/avinassh/fluvio-go/fluvio"
func main() {
// error handling is omitted for brevity
fluvioClient, _ := fluvio.Connect()
defer fluvioClient.Close()
partitionConsumer, _ := fluvioClient.PartitionConsumer("echo", 0)
defer partitionConsumer.Close()
stream, _ := partitionConsumer.Stream(fluvio.NewOffsetFromBeginning(0))
defer stream.Close()
for {
r, _ := stream.Next()
fmt.Printf("Got record: key=%s, value=%s\n", string(r.Key), string(r.Value))
}
}Check the example for the full usage.
package main
import "fmt"
import "github.com/avinassh/fluvio-go/fluvio"
func main() {
// error handling is omitted for brevity
fluvioClient, _ := fluvio.Connect()
defer fluvioClient.Close()
wasmFile := "example/filter.wasm"
config, _ := fluvioClient.ConsumerConfigWithWasmFilter(wasmFile)
defer config.Close()
partitionConsumer, _ := fluvioClient.PartitionConsumer("echo", 0)
defer partitionConsumer.Close()
stream, _ := partitionConsumer.StreamWithConfig(fluvio.NewOffsetFromBeginning(0), config)
defer stream.Close()
for {
r, _ := stream.Next()
fmt.Printf("Got record: key=%s, value=%s\n", string(r.Key), string(r.Value))
}
}The MIT license. Please check LICENSE for more details.
