我在春靴计划中使用Kafka。如果你有一个简单的流程（使用），有很多好处 @KafkaListener , @KafkaHandler )Spring几乎为发展做好了一切准备。
在我的应用程序中，对于相同的消息数据有不同的处理程序。我想使用spel来管理处理头数据的处理程序，但还没有检测到相应的api。
所以我的问题是：有没有可能通过 SpEL 如果我有特殊的标题（例如标题 "X-OPERATION_TYPE":"patch" )? 怎样？
p、 s。
我可以用gof策略作为例子来解决问题，但我希望spring已经有了解决方案。
1条答案
按热度按时间pcww981p1#
ApacheKafka在spring中没有这样的“条件路由”，但是您可以在单个
@KafkaListener与平原if...else或者switch.要获得更全面的路由逻辑，最好看看spring集成：https://docs.spring.io/spring-integration/docs/5.0.9.release/reference/html/messaging-routing-chapter.html