Kafka Connect cassandra 源 - 十进制数据类型的错误 [英] Kafka Connect cassandra source -error for Decimal data type

问题描述

我使用的是 kafka connect cassandra 源连接器 1.0 版本.我在 cassandra 表中有一个十进制数据类型列(价格)，并将其作为来自源连接器的 json 写入 kafka 主题，它以某种字符串格式写入十进制值，例如 "price":"AA==".现在它在我的火花流中出错，同时将浮点数转换为数字格式异常"....??请建议在 kafka 主题中写入值时可能出现的问题.提前致谢.

I am using kafka connect cassandra source connector 1.0 version. I have a decimal datatype column(price) in cassandra table and writing it to the kafka topic as json from source connector,it is writing the decimal value in some string format like like "price":"AA==". Now it is giving error in my spark streaming while converting to float as "number format exception"....?? please suggest what may went wrong while writing the value in kafka topic. Advance thanks.

推荐答案

在连接器文件中用 to_char(fieldname) 包围字段

In connector file surround field with to_char(fieldname)

这篇关于Kafka Connect cassandra 源 - 十进制数据类型的错误的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！