kafka使用者在反序列化具有未知协议的avro消息时出错

m4pnthwp 于 2021-06-06 发布在 Kafka

关注(0)|答案(1)|浏览(329)

在我的用例中，我创建了jdbc-kafka连接器，从oracle表中提取数据并成功地推送到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)

apache-kafka apache-kafka-connect kafka-consumer-api

来源：https://stackoverflow.com/questions/55309363/kafka-consumer-is-failing-with-error-deserializing-avro-message-with-unknown-pro

1条答案

按热度按时间

zbsbpyhn1#

问题是yaml配置文件中的模式注册表url。通知 unknown protocol 错误
把它改成这个（注意我添加了 http:// 协议），它应该可以工作：

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

赞(0）回复(0）举报 2021-06-06

我来回答

kafka使用者在反序列化具有未知协议的avro消息时出错

1条答案

相关问题

热门标签

最新问答