alex-rufo opened a new pull request #5890: Allow routing key per message to RabbitMQ sink connector URL: https://github.com/apache/pulsar/pull/5890 ### Motivation With the current RabbitMQ sink connector, all messages are forwarded to an exchange with the same routing key (specified in the configuration). It would be great to give a bit more flexibility and allow the use of different routing keys for different messages on the same topic. ### Modifications The creation of the queue has been removed from the sink, all messages will be forwarded to the exchange and each consumer will create it's on queue + binding. The configuration has been modified to reflect those changes: added the exchange type and queue name is just required for the source connector.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
