Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Reader: consume from multiple topics #595

Closed
alebabai opened this issue Jan 21, 2021 · 1 comment
Closed

Reader: consume from multiple topics #595

alebabai opened this issue Jan 21, 2021 · 1 comment
Assignees

Comments

@alebabai
Copy link

Describe the solution you'd like
Please, add opportunity to set multiple topics into reader to fetch from.

Supporting documentation
For now it supports single topic and pass it into consumerGroup (if GroupID is specified) as a string slice with one element

kafka-go/reader.go

Lines 656 to 663 in 2b3f682

if r.useConsumerGroup() {
r.done = make(chan struct{})
r.runError = make(chan error)
cg, err := NewConsumerGroup(ConsumerGroupConfig{
ID: r.config.GroupID,
Brokers: r.config.Brokers,
Dialer: r.config.Dialer,
Topics: []string{r.config.Topic},

Related
#564

@alebabai alebabai changed the title Reader: consume from many topics Reader: consume from multiple topics Jan 21, 2021
@dominicbarnes
Copy link
Contributor

This improvement was recently released with v0.4.12

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

2 participants