Kafka Connect cassandra source -error для типа данных Decimal

Question

Я использую kafka connect cassandra source connector 1.0 version.У меня есть столбец десятичного типа данных (цена) в таблице cassandra, и я записываю его в тему kafka как json из исходного соединителя, он записывает десятичное значение в некотором строковом формате, например "price":"AA==".Теперь он выдает ошибку в моем потоке искры при преобразовании в число с плавающей точкой как "исключение формата числа" .... ??Подскажите, пожалуйста, что может пойти не так при написании значения в теме кафки.Заранее спасибо.

Answer 1

Похоже на известную ошибку в Kafka Connect + десятичные дроби.Как предлагается в этом выпуске, вам необходимо выполнить «ручное» преобразование данных из строки в кодировке base64 в BigDecimal:

BigDecimal bigDecimal = new BigDecimal(
    new  BigInteger(Base64.getDecoder().decode("BfXhAA==")), scale);