2017-09-16 453 views
0

ALLSpelEvaluationException:EL1004E:方法调用:方法GetValue(java.lang.String中)不能在java.lang.String中类型中找到

我运行本地server.when弹簧云数据流我运行流,其这样定义

http --port=8787 | transform --expression=payload.getValue('name') | 
jdbc --columns=name --table-name=http_table --password=****** 
--driver-class-name=org.mariadb.jdbc.Driver --username=root --url='jdbc:mysql://127.0.0.1:3306/target_data' 

我使用的处理器变换

​​

但它得到了错误一样,

2017年9月16日20:01:57561 ERROR -kafka侦听器1 osklLoggingErrorHandler:37 - 错误而处理: ConsumerRecord(主题= http_jdbc04.http,分区= 0,偏移= 0, CreateTime = 1505563314419,checksum = 1043955671,序列化密钥大小 = -1,序列化值大小= 102,key = null,值= [B @ 5b1b4ce3) org.springframework.integration.transformer.MessageTransformationException: 未能转换消息;嵌套的异常是 org.springframework.messaging.MessageHandlingException:嵌套 例外是 org.springframework.expression.spel.SpelEvaluationException:EL1004E: 方法调用:方法GetValue(java.lang.String中)不能在 爪哇发现.lang.String type,failedMessage = GenericMessage [payload = {“name”:“world”},headers = {kafka_offset = 0, id = 0392ca58-6644-91fb-9454-a41e83854955,kafka_receivedPartitionId = 0, contentType = application/json; charset = UTF-8, kafka_receivedTopic = http_jdbc04.http,timestamp = 1505563317552}]

这里是我遵循spring-cloud-dataflow-docs

和弹簧云数据流版本的文档:

1.spring云数据流的本地服务器1.2.3.RELEASE

2.Java:1.8.0

回答

0

我解决了这个问题。

这可不行:

​​

,你应该使用#jsonPath(payload, '<json path expression>')

相关问题