()
| 12 | ) |
| 13 | |
| 14 | func main() { |
| 15 | parser, err := kmsgparser.NewParser() |
| 16 | if err != nil { |
| 17 | log.Fatalf("unable to create parser: %v", err) |
| 18 | } |
| 19 | defer parser.Close() |
| 20 | |
| 21 | kmsg := parser.Parse() |
| 22 | |
| 23 | for msg := range kmsg { |
| 24 | fmt.Fprintf(os.Stderr, "(%d) - %s: %s", msg.SequenceNumber, msg.Timestamp.Format(time.RFC3339Nano), msg.Message) |
| 25 | } |
| 26 | } |