From 99f4d3cca252326678f06b9089b1d45b3f7e61a5 Mon Sep 17 00:00:00 2001 From: Piotr Konopka Date: Fri, 24 Oct 2025 09:00:06 +0200 Subject: [PATCH] use a group name for the kafka reader otherwise, we will not get all messages among multiple partitions/replicas. --- core/integration/lhc/plugin.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/integration/lhc/plugin.go b/core/integration/lhc/plugin.go index bb427655..1d5853d9 100644 --- a/core/integration/lhc/plugin.go +++ b/core/integration/lhc/plugin.go @@ -70,7 +70,7 @@ func (p *Plugin) Init(_ string) error { // use a background context for reader loop; Destroy will Close the reader p.ctx = context.Background() - p.reader = cmnevent.NewReaderWithTopic(dipClientTopic, "", true) + p.reader = cmnevent.NewReaderWithTopic(dipClientTopic, "o2-aliecs-core.lhc", true) if p.reader == nil { return errors.New("could not create a kafka reader for LHC plugin")