全部
我使用本地服务器运行spring云数据流。当我运行这样定义的流时
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'
我使用处理器转换
transform --expression=payload.getValue('name')
但它有这样的错误。
2017-09-16 20:01:57,561 ERROR-Kafka-侦听器-1 o. s. k. l. LoggingError Handler: 37-处理时出错:消费者记录(主题=http_jdbc04.http,分区=0,偏移量=0,CreateTime=1505563314419,校验和=1043955671,序列化密钥大小=-1,序列化值大小=102,密钥=null,值=[B@5b1b4ce3)org.springframework.integration.transformer.MessageTransformation异常:转换消息失败;嵌套异常是org.springframework.messaging.MessageHandling异常:嵌套异常是org.springframework.expression.spel.SpelE的异常:EL1004E:方法调用:在java.lang.字符串类型上找不到方法getValue(java.lang.String),失败消息=通用消息[有效载荷={"name":"world"},标头={kafka_offset=0,id=0392ca58-6644-91fb-9454-a41e83854955,kafka_receivedPartitionId=0,内容类型=应用程序/json;charset=UTF-8,kafka_receivedTopic=http_jdbc04.http,time
以下是我关注的Spring云数据流文档
以及Spring云数据流版本:
1.spring云数据流本地服务器1.2.3.RELEASE
2.Java:1.8.0
我解决了这个问题。
这是行不通的:
transform --expression=payload.getValue('name')
您应该使用< code>#jsonPath(有效负载,
我得到了这个错误,我不知道问题可能在哪里。“userid”列位于数据库和bean中。有人知道吗?
我正在学习java,我写了这个程序,它在我的大学电脑上编译成功,但在我的家庭电脑上没有编译。有谁能帮助我吗?
我正在尝试创建一个JMeter负载测试。我需要测试获取一个示例日志文件并更改其名称。我能找到的唯一方法是在BeanShell预处理器中复制该文件,但我得到了以下错误: 我使用的代码如下:
问题内容: 我正在尝试创建JMeter负载测试。我需要测试以获取示例日志文件并更改其名称。我能找到的唯一方法是在BeanShell预处理器中复制文件,但出现以下错误: 我使用的代码如下: filename,global_counter和file_counter是jmeter变量。 有人知道我为什么收到此错误吗?beanshell预处理器是否无法以我尝试使用的方式工作? 问题答案: 我的 猜测 是问
我试图用java创建一个分数计算器,我使用drop box int Joptionpane来显示算术运算,但是每当我编译代码时,总是会出现错误。 这是我得到的全部错误。 .java:47:错误:找不到适合showInputDialog(,String,int,,String[],String)的方法String input=(String)JOptionPane。showInputDialog(n
问题内容: 我正在使用登录功能,但是遇到了我无法弄清的错误。 这是我的模型登录类: 最后一个函数给出错误“ 在类中找不到方法’close’ ”,“ 在主题类中找不到引用的方法。 ” 这是我的数据库类: 路径是正确的,事实并非如此。可能是什么错误? 问题答案: PhpStorm无法确定您的字段是什么类型。您可以通过简单的PHPDoc注释提供typehint来提供帮助: