Merge pull request #2 from Netcracker/support-kafka-consumer-metrics

Support kafka consumer metrics

Author: denisanfimov

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
 }

go.mod

@@ -6,7 +6,7 @@ toolchain go1.23.1
 
 require (
 	github.com/docker/go-connections v0.5.0
-	github.com/netcracker/qubership-core-lib-go-bg-kafka/v3 v3.0.0-20250410110823-7e14c200dc04
+	github.com/netcracker/qubership-core-lib-go-bg-kafka/v3 v3.0.0-20250418110345-8cb15b98251a
 	github.com/netcracker/qubership-core-lib-go-bg-state-monitor/v2 v2.0.0-20250410105207-ba4bfd983c8d
 	github.com/netcracker/qubership-core-lib-go-maas-client/v3 v3.0.0-20250410104652-3cf8d92a547f
 	github.com/netcracker/qubership-core-lib-go-maas-segmentio/v3 v3.0.0-20250410112738-a235fd6d6731

go.sum

@@ -243,8 +243,8 @@ github.com/morikuni/aec v1.0.0 h1:nP9CBfwrvYnBRgY6qfDQkygYDmYwOilePFkwzv4dU8A=
 github.com/morikuni/aec v1.0.0/go.mod h1:BbKIizmSmc5MMPqRYbxO4ZU0S0+P200+tUnFx7PXmsc=
 github.com/mwitkow/go-conntrack v0.0.0-20161129095857-cc309e4a2223/go.mod h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U=
 github.com/mwitkow/go-conntrack v0.0.0-20190716064945-2f068394615f/go.mod h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U=
-github.com/netcracker/qubership-core-lib-go-bg-kafka/v3 v3.0.0-20250410110823-7e14c200dc04 h1:OmqOwofk7uZ6ZcnQBaBpM9QUzQbAPIvFZl3EvC4+Cbw=
-github.com/netcracker/qubership-core-lib-go-bg-kafka/v3 v3.0.0-20250410110823-7e14c200dc04/go.mod h1:KjhzUbD7jdYAzG6xN0W0/OExsP6a26/4sqLs8Usxeyo=
+github.com/netcracker/qubership-core-lib-go-bg-kafka/v3 v3.0.0-20250418110345-8cb15b98251a h1:svIH3KDPOzsWqtvKDwB349Q6YNFjxFLCWo/JnAtIRxQ=
+github.com/netcracker/qubership-core-lib-go-bg-kafka/v3 v3.0.0-20250418110345-8cb15b98251a/go.mod h1:KjhzUbD7jdYAzG6xN0W0/OExsP6a26/4sqLs8Usxeyo=
 github.com/netcracker/qubership-core-lib-go-bg-state-monitor/v2 v2.0.0-20250410105207-ba4bfd983c8d h1:UAC95LhE+NsmRv4WavRl4RiA2xzp2kIrfJcO+HY9bSM=
 github.com/netcracker/qubership-core-lib-go-bg-state-monitor/v2 v2.0.0-20250410105207-ba4bfd983c8d/go.mod h1:0PBcMxbGaqeAeGSvgmyS5BeXQAwgPBKObg6xkRpGqyQ=
 github.com/netcracker/qubership-core-lib-go-maas-client/v3 v3.0.0-20250410104652-3cf8d92a547f h1:ISeGVnb4y7YK/+tbjNlzh1OhSCbAhIeXoHwJIrOIbSQ=