Add Message HighWaterMark method implementation

NC_Danil NC_Basin · NC_Danil NC_Basin · commit 22f7b7e5de67 · 2025-04-18T15:12:37.000+05:00
diff --git a/consumer.go b/consumer.go
@@ -66,6 +66,10 @@ func (m *msgAdapter) Topic() string {
 	return m.nativeMessage.Topic
 }
 
+func (m *msgAdapter) HighWaterMark() int64 {
+	return m.nativeMessage.HighWaterMark
+}
+
 func (m *msgAdapter) Offset() int64 {
 	return m.nativeMessage.Offset
 }

Original file line number	Diff line number	Diff line change
`@@ -66,6 +66,10 @@ func (m *msgAdapter) Topic() string {`
`66`	`66`	`return m.nativeMessage.Topic`
`67`	`67`	`}`
`68`	`68`
	`69`	`+func (m *msgAdapter) HighWaterMark() int64 {`
	`70`	`+ return m.nativeMessage.HighWaterMark`
	`71`	`+}`
	`72`	`+`
`69`	`73`	`func (m *msgAdapter) Offset() int64 {`
`70`	`74`	`return m.nativeMessage.Offset`
`71`	`75`	`}`