-
Notifications
You must be signed in to change notification settings - Fork 526
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
Kafka sink: dynamic topic name #16731
Labels
Milestone
Comments
Thanks for providing this interesting requirement! |
It is not yet blocking as we already have a "big topic" and filter on the consumer side if it needs to process the message or not, however most of the time they will ignore it. If each of them had dedicated topic it would be more efficient :) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Is your feature request related to a problem? Please describe.
I would like to choose the topic name depending on the value of a column. This way I can have consumers A consuming topic A and doing something specific, and have consumer B consuming topic B and doing something else.
Both are totally exclusive, consumer A doesn't need to process topic B and vice-versa.
Describe the solution you'd like
A bit like #15835.
It looks however that there is a limitation in the documentation
One sink can only correspond to one topic.
Describe alternatives you've considered
No response
Additional context
No response
The text was updated successfully, but these errors were encountered: