kafkaflow
kafkaflow copied to clipboard
Deduplicate topic declaration before trying to create them
Description
Deduplicate topic list before sending it to AdminClient. Handle case where client call multiple CreateTopicIfNotExists with same topic name.
Fixes #382
How Has This Been Tested?
Tested on our solution
Checklist
- [x] My code follows the style guidelines of this project
- [x] I have performed a self-review of my own code
- [ ] I have added tests to cover my changes
- [ ] I have made corresponding changes to the documentation
Disclaimer
By sending us your contributions, you are agreeing that your contribution is made subject to the terms of our Contributor Ownership Statement
Sorry I thought I answered but did not. Yes I agree with your solution.
Sorry I thought I answered but did not. Yes I agree with your solution.
@kYann are you available to review the PR applying that?
Yes !