apache-kafka - Kafka 与 RabbitMQ 接收器连接

Question

我想使用 Kafka 连接从 Kafka 主题中读取事件并将它们写入 RabbitMQ。为此，我需要使用RabbitMQ sink。

来自 Kafka 的每个事件都应该发送到不同的队列（基于事件结构中的某些字段），这意味着应该使用不同的路由键。据我所知，有一个选项可以在接收器配置中配置静态路由密钥。是否有任何选项可以根据事件动态配置它以实现所需的行为？

标签： apache-kafkarabbitmqapache-kafka-connect