Kafka AVRO не может отправить значение как дату
у меня есть схема avro:
"fields" : [ {
"name" : "errortime",
"type": [ "null", {
"type": "long",
"logicalType": "timestamp-millis"
}]
которые создают класс java с полем как joda DateTime errortime.
Когда я пытаюсь сериализовать в формат avro, я получаю следующую ошибку:
Caused by: org.apache.avro.AvroRuntimeException: Unknown datum type org.joda.time.DateTime: 2018-05-02T12:32:27.563Z
Как избежать этой проблемы?
Привет. для создания объекта java avro я использую плагин gradle (com.commercehub.gradle.plugin.avro) для сериализации я использую KafkaAvroSerializer () с реестром kafka
Мой первый вопрос был больше о том, как вы создаете экземпляр класса avro (создавая объект), который сериализуется. как вы заполняете поле даты? Вы пробовали воспроизвести это как модульный тест?
эта проблема не в моем коде, проблема в коннекторе приемника kafka jdbc
Мне было бы полезно увидеть ваш код и предоставить весь журнал ошибок ..
Я считаю, что это ошибка: issues.apache.org/jira/browse/AVRO-1891. но если вы знаете, как решить, я предоставлю всю информацию
Была та же проблема, для обходного пути Проверьте решение, опубликованное здесь
как вы создаете свой объект avro и как вы сериализуете? вы используете schemaregistry + KafkaAvroSerializer? или DatumWriter?