我的应用程序从ibmq获取消息，并根据内容将其路由到不同的kafka主题。kafka mq源连接器可以将mq中的事件带到1个kafka主题，我们可以在kafka mq连接器中执行基于消息的路由吗？或者我们必须编写一个kstream应用程序来根据内容负载进行路由吗
jqjz2hbq1#
单个消息转换api允许您根据消息的内容更改主题，但是afaik没有一个已经存在的主题，因此您需要编写自己的主题。另一种方法是，如您所说，使用kafka流或ksql进行路由。本文也可能有用：https://www.confluent.io/blog/putting-events-in-their-place-with-dynamic-routing
1条答案
按热度按时间jqjz2hbq1#
单个消息转换api允许您根据消息的内容更改主题，但是afaik没有一个已经存在的主题，因此您需要编写自己的主题。
另一种方法是，如您所说，使用kafka流或ksql进行路由。
本文也可能有用：https://www.confluent.io/blog/putting-events-in-their-place-with-dynamic-routing