From 22f7b7e5de674c2a28055ae341993105a870b8e6 Mon Sep 17 00:00:00 2001 From: NC_Danil NC_Basin Date: Fri, 18 Apr 2025 15:12:37 +0500 Subject: [PATCH 1/2] Add Message HighWaterMark method implementation --- consumer.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/consumer.go b/consumer.go index 2ff532f..396e4bf 100644 --- 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 } From 9d2beedc90f79a70a14c9e60baad8177575161be Mon Sep 17 00:00:00 2001 From: NC_Danil NC_Basin Date: Fri, 18 Apr 2025 16:19:07 +0500 Subject: [PATCH 2/2] Update bg-kafka lib version --- go.mod | 2 +- go.sum | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/go.mod b/go.mod index a7a11f0..cdb63c0 100644 --- a/go.mod +++ b/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 diff --git a/go.sum b/go.sum index ae28636..2701cbf 100644 --- a/go.sum +++ b/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=