Потребитель Kafka не работает с ошибкой десериализации сообщения Avro для идентификатора - PullRequest
Новая
       13

Потребитель Kafka не работает с ошибкой десериализации сообщения Avro для идентификатора

1 голос
/ 23 марта 2019

В моем случае я создал соединитель JDBC kafka, извлек данные из таблицы оракулов и успешно отправил их в тему kafka, но когда я пытаюсь прочитать сообщения из этой темы kafka, у меня возникает проблема десериализации, как указано ниже. 

org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id 2
Caused by: java.net.MalformedURLException: unknown protocol: localhost
        at java.net.URL.<init>(URL.java:593)
        at java.net.URL.<init>(URL.java:483)
        at java.net.URL.<init>(URL.java:432)
        at io.confluent.kafka.schemaregistry.client.rest.RestService.sendHttpRequest(RestService.java:124)
        at io.confluent.kafka.schemaregistry.client.rest.RestService.httpRequest(RestService.java:188)
        at io.confluent.kafka.schemaregistry.client.rest.RestService.getId(RestService.java:330)

1 Ответ

2 голосов
/ 23 марта 2019

Проблема заключается в URL-адресе реестра схемы в файле конфигурации YAML.

Измените его на следующее (заметьте, я добавил протокол http:// в строку URL), и он должен работать: 

schema:
  version: latest2
  registry:
     url: http://localhost:8081
...