kafka connect jdb c sink Схема значений должна иметь тип Struct - PullRequest
Новая
       39

kafka connect jdb c sink Схема значений должна иметь тип Struct

1 голос
/ 18 февраля 2020

Я хочу использовать разъем kafka connect jdb c для раковины с конвертером avro.

Это мои конфигурации avro: 

"key.converter":"io.confluent.connect.avro.AvroConverter",
"key.converter.schema.registry.url" : "http://myurl.com" ,
"value.converter":"io.confluent.connect.avro.AvroConverter",
"value.converter.schema.registry.url" : "http://myurl.com" ,

Схемы установлены на false 

key.converter.schemas.enable=false
value.converter.schemas.enable=false

Теперь, когда я запускаю соединитель, я получаю эту ошибку

Причина: org. apache .kafka.connect.errors.ConnectException: Схема значений должна иметь тип Struct

Из того, что я прочитал, Struct для json схем, верно? у меня не должно быть никакой структуры, если я использую схему avro?

Типы схем Avro: запись, перечисление, массивы, карты, объединения и исправлены, но структура отсутствует.

Что такое я скучаю?

Спасибо !!

1 Ответ

1 голос
/ 19 февраля 2020

Запись Avro создает тип данных Struct Connect.

Ошибка говорит о том, что ваши данные не являются записями.

Для схем задано значение false

Эти свойства ничего не значат для конвертера Avro. Avro всегда имеет схему

Я хочу использовать разъем kafka connect jdb c для приемника с преобразователем avro.

Затем производителю необходимо отправить записи со схемами. Это включает в себя записи Avro или JSON со схемами включенными

...