kafka conect cassandra source -error为十进制数据类型
我正在使用kafka connect cassandra source connector 1.0版本。我在cassandra表中有一个十进制数据类型列（价格），并将其作为json从源连接器写入kafka主题，它正在以类似的字符串格式写入十进制值"price":"AA=="。现在它在我的spark流中给出错误，同时转换为float为“数字格式异常”.... 请在kafka主题中写下值时建议可能出现的问题。
展开
收起
1
条回答
写回答
写回答
-
社区小助手是spark中国社区的管理员，我会定期更新直播回顾等资料和文章干货，还整合了大家在钉群提出的有关spark的问题及回答。它看起来像Kafka Connect + Decimals中的已知错误。正如问题中所提出的，您需要执行从base64编码的字符串到“的手动”转换BigDecimal：
BigDecimal bigDecimal = new BigDecimal(
new BigInteger(Base64.getDecoder().decode("BfXhAA==")), scale);2019-07-17 23:20:02赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
阿里云NoSQL数据库提供了一种灵活的数据存储方式，可以支持各种数据模型，包括文档型、图型、列型和键值型。此外，它还提供了一种分布式的数据处理方式，可以支持高可用性和容灾备份。包含Redis社区版和Tair、多模数据库 Lindorm、MongoDB 版。
热门讨论
热门文章
redis查看某个前缀键值数量
3861
lettuce RedisClient报错WRONGPASS invalid username-pa
616
云数据库 Redis报错command keys must in same slot
1179
如何将Redis 5.0版本升级到7.0？
153
连接Redis报错“WRONGPASS invalid username-password pair”
418
cassandra启动不起来怎么排查原因呀？system.log日志打到这里就没有了
196
Redis代理模式访问报错 ERR bad lua script for redis cluster
2663
Node连接Redis实例用户认证提示“Ready check failed: NOAUTH Authentication required”错误
218
Centos 部署Tair 社区版，使用 Python 和 Tair SDK 连接 Ta连接存在问题
15
Redis连接报错invalid password
725
展开全部
redis4.0、codis、阿里云redis 3种redis集群对比分析
41574
NoSQL最新现状和趋势：云NoSQL数据库将成重要增长引擎
38463
MongoDB 生态 - 可视化管理工具
36065
Apache Cassandra 简介
23741
PostgreSQL内核扩展之 - ElasticSearch同步插件
25587
MongoDB查询优化：从 10s 到 10ms
34225
MongoDB 如何使用内存？为什么内存满了？
23103
Redis内存分析方法
20062
HBase实战 | 从MySQL到HBase：数据存储方案转型的演进
14400
MongoDB CPU 利用率高，怎么破？
13767
展开全部
