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

Reviewed-on: #160
correction create opts
2026-01-30 09:58:17 +03:00 · 2026-01-30 09:52:41 +03:00
1 changed files with 16 additions and 13 deletions
--- a/kgo.go
+++ b/kgo.go
@@ -568,7 +568,8 @@ func (b *Broker) fnSubscribe(ctx context.Context, topic string, handler interfac
 		messagePool:  messagePool,
 	}
-	kopts := append(b.kopts,
+	kopts := append(
 		[]kgo.Opt{
 			kgo.ConsumerGroup(options.Group),
 			kgo.ConsumeTopics(topic),
 			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.AutoCommitMarks(),
 			kgo.WithHooks(sub),
 		},
 		b.kopts...,
 	)
 	if options.Context != nil {
Author	SHA1	Message	Date
Василий Толстов	d0a959611d	Merge pull request 'correction create opts' (#160 ) from devstigneev/micro-broker-kgo:fix_opts into v4 Some checks failed coverage / build (push) Failing after 3m15s Details test / test (push) Failing after 17m25s Details sync / sync (push) Failing after 28s Details Reviewed-on: #160	2026-01-30 09:58:17 +03:00
Evstigneev Denis	acb7fd2b11	correction create opts Some checks failed coverage / build (pull_request) Failing after 2m25s Details test / test (pull_request) Failing after 4m35s Details lint / lint (pull_request) Failing after 4m43s Details	2026-01-30 09:52:41 +03:00