From 3be7cb61fc78af2155748b31e93eda8d2579db63 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=AD=B1=E7=91=9C?= Date: Thu, 1 Dec 2022 19:12:19 +0800 Subject: [PATCH] add api GetOffsetDiffMap --- api.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/api.go b/api.go index 449f754e..b0a203ef 100644 --- 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) {