We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
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: kafka.ReaderConfig{ Brokers: strings.Split(getConsumerServers(a.Kafka), ","), GroupID: consumerCfg.ConsumerGroup, GroupTopics: consumerCfg.Topics, MaxWait: 2 * time.Second, CommitInterval: time.Second, Logger: l, ErrorLogger: l, },
I added logger and error logger. I would be great if we saw log about topic not found or smth.
The text was updated successfully, but these errors were encountered:
Thank you! We can ask this question to the segmentio-kafkago @keremcankabadayi
Sorry, something went wrong.
feat: added topic exists check (Trendyol#59)
72deca3
segmentio/kafka-go#1142 here related issue, @dilaragorum will also check related pr #111
feat: added topic exists check (#59) (#131)
ca225fb
* feat: added topic exists check (#59) * chore: * chore: dummy * feat: implement topic verify process * chore: lint fix * feat: bump kafka-cronsumer verify topic commit * feat: add verifyTopicOnStartup flag --------- Co-authored-by: keremcankabadayi <keremcankabadayi@gmail.com>
implemented, thank you for your contribution @keremcankabadayi <3 commit
keremcankabadayi
dilaragorum
No branches or pull requests
I added logger and error logger. I would be great if we saw log about topic not found or smth.
The text was updated successfully, but these errors were encountered: