spring-boot - 如何在@StreamListener 中添加日期条件

Question

假设，我能够通过 Kafka 或 RabbitMQ 发送消息并使用 @StreamListener 使用它们。

Binders 是为 content-type = 'application/json' 配置的，所以我想可以在负载上添加条件。

我的要求是仅当字段的日期早于 now() 时才获取元素。当此条件为真时，将消耗所有其他元素。

例如，我希望是这样的:

@StreamListener(value = INPUT, condition = "data.startDate > now()")
public void onMessage(@Payload Data data) { 
    // ...
}

第一个问题是我收到错误:EL1008E:无法在类型为“byte[]”的对象上找到属性或字段“startDate”- 可能不是公共(public)的或无效？

Answer 1

这是正确的，因为有效载荷没有转换为任何类型，而是以 byte[] 的原始形式存在。请参阅this section特别是 “条件上下文中的内容类型协商” 子部分。

但是，对于您的情况，您可以简单地将表达式修改为类似于 new String(payload)....，知道它始终是 byte[]在转换之前