У меня проблема с сериализацией Apache Kafka и Avro.
В свойствах моего производителя я использую io.confluent.kafka.serializers.KafkaAvroSerializer для сериализации значений.
В моем классе Java у меня есть поля с типом: java.sql.Timestamp и java.time.LocalDateTime .
Я создаю свой классиз авро-схемы и отправьте ее в kafka.
Авро-схема для java.sql.Timestamp выглядит так:
{"name" : "firstTime" ,"type" : [{"type":"string","java-class":"java.sql.Timestamp"},"null"]},
Но когда я отправляю свой объект вКафка я ловлю исключение:
org.apache.avro.AvroRuntimeException: avro unknown datum java.sql.Timestamp
Моя версия avro 1.8.2 .Apache kafka - это 2.1.0 .
Пожалуйста, помогите мне найти лучший способ отправки таких записей.