我的Camel路由需要从入站交换对象访问kafka.HEADERS标头。其中一个标题是标题列表,其中值类型是RecordHeader。我想访问RecordHeader之一(例如leadEquipmentId)并将其与String进行比较。请有人建议怎么做?此语法不起作用:
<spel>#{#{request.headers['kafka.HEADERS']}['leadEquipmentId']} == 'SomeEquipmentId'</spel>
RecordHeaders
不是Map
所以你不能使用MapAccessor
(['leadEquipmentId']
)。
尝试
#{new String(request.headers['kafka.HEADERS'].lastHeader('leadEquipmentId').value())} == 'SomeEquipmentId'