KSQL go client
A barebones go client for interacting with Confluent's KSQL
Examples
List all Streams
c := ksql.NewClient("http://localhost:8088")
log.Println("=>>> Streams")
streams, err := c.ListStreams()
if err != nil {
log.Fatal(err)
}
for i, v := range streams {
log.Printf("Stream %d: %s", i, v.Name)
}List all Tables
c := ksql.NewClient("http://localhost:8088")
log.Println("=>>> Tables")
tables, err := c.ListTables()
if err != nil {
log.Fatal(err)
}
for i, v := range tables {
log.Printf("Table %d: %s", i, v.Name)
}Query stream
c := ksql.NewClient("http://localhost:8088")
log.Println("=>>> Forever Query :")
ch := make(chan *ksql.QueryResponse)
go c.Query(ksql.Request{KSQL: "SELECT pageid FROM pageviews_original;"}, ch)
for {
select {
case msg := <-ch:
log.Println(msg.Row)
}
}