Spring Boot Kafka 消息传递。如何使用 SpEL 管理处理程序访问答案

【问题标题】：Spring boot Kafka messaging. How to use SpEL to manage handler accessSpring Boot Kafka 消息传递。如何使用 SpEL 管理处理程序访问
【发布时间】：2018-11-08 16:02:31
【问题描述】：

我在 Spring Boot 项目中使用 Kafka。如果您有简单的流程（使用@KafkaListener、@KafkaHandler）并且spring 为开发准备了几乎所有东西，那么会有很多好处。

在我的应用程序中，我对相同的消息数据有不同的处理程序。我想使用 SpEL 来管理处理标头数据的处理程序，但我没有检测到相应的 API。

所以我的问题是：是否可以通过SpEL 管理我的处理程序，以防我有特殊的标头（例如标头"X-OPERATION_TYPE":"patch"）？怎么样？

附言

我可以以 GoF 策略为例进行变通，但我希望 Spring 已经为这种情况提供了解决方案。

【问题讨论】：

标签： spring spring-boot apache-kafka spring-kafka spring-el

【解决方案1】：

对于 Apache Kafka，Spring 中没有这样的“条件路由”，但您可以在单个 @KafkaListener 中手动执行该路由，使用普通的 if...else 或 switch。

对于更全面的路由逻辑，最好看看 Spring Integration：https://docs.spring.io/spring-integration/docs/5.0.9.RELEASE/reference/html/messaging-routing-chapter.html

【讨论】：