Привет! Вопрос) Гружу из confluent kafka данные с помощью kafka streams (scala). Данные

Question

Привет! Вопрос) Гружу из confluent kafka данные с помощью kafka streams (scala). Данные

в avro, схема в schema registry. Есть авторизация через ssl.
Когда делаю poll, падает вот с такой ошибкой:
org.apache.kafka.common.errors.SerializationException: Error deserializing key/value for partition my-topic-0 at offset 2887475. If needed, please seek past the record to continue consumption.
Caused by: org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id 4532
Caused by: org.apache.kafka.common.errors.SerializationException: Could not find class my.schema.registry.my-topic specified in writer's schema whilst finding reader's schema for a SpecificRecord.
Почему-то кафка пытается у меня найти класс my.schema.registry.my-topic которого у меня нет. Как я понимаю, пытается оттуда взять структуру данных, хотя она есть в schema registry.
Шо делать? И почему вообще такое происходит?

#kafka #russian #software

0

06.09.2019

1 ответов

23 просмотра

Vik Gamov · Accepted Answer

Vik Gamov

Код можно где-то поглядеть? Там у вас скала, конечно... Неприятно будет, но надо помочь

0

06.09.2019

52 похожих чатов

Привет! Вопрос) Гружу из confluent kafka данные с помощью kafka streams (scala). Данные

1 ответов

Похожие вопросы