Skip to content

Commit 94c397f

Browse files
committed
use a group name for the kafka reader
otherwise, we will not get all messages among multiple partitions/replicas.
1 parent f67074c commit 94c397f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/integration/lhc/plugin.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ func (p *Plugin) Init(_ string) error {
7070
// use a background context for reader loop; Destroy will Close the reader
7171
p.ctx = context.Background()
7272

73-
p.reader = cmnevent.NewReaderWithTopic(dipClientTopic, "", true)
73+
p.reader = cmnevent.NewReaderWithTopic(dipClientTopic, "o2-aliecs-core.lhc", true)
7474

7575
if p.reader == nil {
7676
return errors.New("could not create a kafka reader for LHC plugin")

0 commit comments

Comments
 (0)