Merge pull request #44 from njhartwell/master

Adding consumer-lag
fgeller · Mar 9, 2017 · 1cab06d · 1cab06d
2 parents d3e8974 + dcab6be
commit 1cab06d
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/offset.go b/offset.go
@@ -47,6 +47,7 @@ type offsets struct {
 	Partition       int32  `json:"partition"`
 	PartitionOffset int64  `json:"partition-offset"`
 	ConsumerOffset  *int64 `json:"consumer-offset,omitempty"`
+	ConsumerLag     *int64 `json:"consumer-lag,omitempty"`
 }
 
 func (cmd *offsetCmd) parseFlags(as []string) offsetArgs {
@@ -182,6 +183,10 @@ func (cmd *offsetCmd) do(q chan struct{}) {
 					if cmd.group != "" {
 						off.ConsumerGroup = cmd.group
 						off.ConsumerOffset = &co
+						if co > 0 {
+							cl := po - co
+							off.ConsumerLag = &cl
+						}
 					}
 					cmd.printOffset(off)
 					select {