This is an automated email from the ASF dual-hosted git repository.
dinglei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new cad2f66 add api GetOffsetDiffMap (#965)
cad2f66 is described below
commit cad2f666827200ca89ef1db0a4ecf30ff2bda45d
Author: Kay Du <[email protected]>
AuthorDate: Thu Dec 1 20:06:18 2022 +0800
add api GetOffsetDiffMap (#965)
Co-authored-by: 筱瑜 <[email protected]>
---
api.go | 3 +++
1 file changed, 3 insertions(+)
diff --git a/api.go b/api.go
index 449f754..b0a203e 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) {
