this repo has no description
remove logging metric thing
+16
-16
+16
-16
consumer.go
+16
-16
consumer.go
···
49
49
50
50
cursor := time.Now().Add(5 * -time.Minute).UnixMicro()
51
51
52
-
// Every 5 seconds print the events read and bytes read and average event size
53
-
go func() {
54
-
ticker := time.NewTicker(5 * time.Second)
55
-
for {
56
-
select {
57
-
case <-ticker.C:
58
-
eventsRead := c.EventsRead.Load()
59
-
if eventsRead == 0 {
60
-
continue
61
-
}
62
-
bytesRead := c.BytesRead.Load()
63
-
avgEventSize := bytesRead / eventsRead
64
-
logger.Info("stats", "events_read", eventsRead, "bytes_read", bytesRead, "avg_event_size", avgEventSize)
65
-
}
66
-
}
67
-
}()
52
+
// // Every 5 seconds print the events read and bytes read and average event size
53
+
// go func() {
54
+
// ticker := time.NewTicker(5 * time.Second)
55
+
// for {
56
+
// select {
57
+
// case <-ticker.C:
58
+
// eventsRead := c.EventsRead.Load()
59
+
// if eventsRead == 0 {
60
+
// continue
61
+
// }
62
+
// bytesRead := c.BytesRead.Load()
63
+
// avgEventSize := bytesRead / eventsRead
64
+
// logger.Info("stats", "events_read", eventsRead, "bytes_read", bytesRead, "avg_event_size", avgEventSize)
65
+
// }
66
+
// }
67
+
// }()
68
68
69
69
if err := c.ConnectAndRead(ctx, &cursor); err != nil {
70
70
return fmt.Errorf("connect and read: %w", err)