From 8c8705581e5f6d854eb04970dcf1918bb0991b3e Mon Sep 17 00:00:00 2001 From: Gregory Eremin Date: Sun, 11 Nov 2018 15:04:07 +0100 Subject: [PATCH] Don't forget to decode all rows in the test command --- cmd/main.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/cmd/main.go b/cmd/main.go index e2650e0..bc3b3fe 100644 --- a/cmd/main.go +++ b/cmd/main.go @@ -46,6 +46,13 @@ func main() { ts := time.Unix(int64(evt.Header.Timestamp), 0).Format(time.RFC3339) log.Printf("Event received: %s %s, %d\n", evt.Header.Type.String(), ts, off) off = evt.Header.NextOffset + + if evt.Table != nil { + _, err := evt.DecodeRows() + if err != nil { + log.Fatalf("Failed to parse rows event: %v", err) + } + } } }