Kafka连接MSSQL Server十进制转换

Question

我们正在使用 Confluent JDBC connector 从 MS SQL 数据库中提取数据。我们在提取列数据格式为 decimal(10,2) 的十进制列时遇到问题，该格式将数据作为字节而不是十进制传递。 "charge":{"bytes":"\u0006Iô"}（这是从消费者的控制台获取的，显示了模式注册表结构）。

有没有人以前见过连接器的这种行为并且知道我们将如何解决？

干杯

Answer 1

目前对在 .Net 中使用 Schema Registry 的支持有限。因此，我们不得不手动操作字节数组来产生小数。

这涉及填充和反转字节数组，对精度和比例进行假设，并根据第一个值（> 128 == 负）确定是正数还是负数。我们还必须为每个负小数附加一个 .01。