【发布时间】：2017-12-10 16:58:05
【问题描述】：
我们正在使用Confluent JDBC connector 从 MS SQL 数据库中提取数据。我们在提取列数据格式为decimal(10,2) 的十进制列时遇到问题，该列将数据作为字节而不是十进制传递。 "charge":{"bytes":"\u0006Iô"}（这是从消费者的控制台中获取的，并显示了架构注册表结构）。
之前有没有人看到过连接器的这种行为并知道我们将如何解决？
干杯
【问题讨论】：
-
这是列的架构注册表定义：
{"name":"charge","type":["null",{"type":"bytes","scale":2,"precision":64,"connect.version":1,"connect.parameters":{"scale":"2"},"connect.name":"org.apache.kafka.connect.data.Decimal","logicalType":"decimal"}],"default":null}
标签： c# sql-server avro kafka-consumer-api apache-kafka-connect