add api GetOffsetDiffMap (#965)

Co-authored-by: 筱瑜 <[email protected]>
apache · Dec 1, 2022 · cad2f66 · cad2f66
1 parent 0742aac
commit cad2f66
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/api.go b/api.go
@@ -70,6 +70,9 @@ type PushConsumer interface {
 
 	// Resume the consumption
 	Resume()
+
+	// GetOffsetDiffMap Get offset difference map
+	GetOffsetDiffMap() map[string]int64
 }
 
 func NewPushConsumer(opts ...consumer.Option) (PushConsumer, error) {