unistack-org/micro-broker-kgo
4
0
Fork 2
Code Issues 4 Pull Requests 4 Actions 2 Packages Projects Releases 85 Wiki Activity

Merge pull request 'correction create opts' (#160) from devstigneev/micro-broker-kgo:fix_opts into v4

Browse Source 
Reviewed-on: #160
This commit is contained in:
Василий Толстов
2026-01-30 09:58:17 +03:00
parent 5080a52834 acb7fd2b11
commit 3db914d259
1 changed files with 16 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
kgo.go
View File

@@ -568,7 +568,8 @@ func (b *Broker) fnSubscribe(ctx context.Context, topic string, handler interfac
messagePool: messagePool, messagePool: messagePool,
} }
kopts := append(b.kopts, kopts := append(
[]kgo.Opt{
kgo.ConsumerGroup(options.Group), kgo.ConsumerGroup(options.Group),
kgo.ConsumeTopics(topic), kgo.ConsumeTopics(topic),
kgo.ConsumeResetOffset(kgo.NewOffset().AtStart()), kgo.ConsumeResetOffset(kgo.NewOffset().AtStart()),
@@ -581,6 +582,8 @@ func (b *Broker) fnSubscribe(ctx context.Context, topic string, handler interfac
kgo.AutoCommitCallback(sub.autocommit), kgo.AutoCommitCallback(sub.autocommit),
kgo.AutoCommitMarks(), kgo.AutoCommitMarks(),
kgo.WithHooks(sub), kgo.WithHooks(sub),
},
b.kopts...,
) )
if options.Context != nil { if options.Context != nil {