Kafka 消费者因使用未知协议反序列化 Avro 消息而失败答案

【问题标题】：Kafka consumer is failing with Error deserializing Avro message with unknown protocolKafka 消费者因使用未知协议反序列化 Avro 消息而失败
【发布时间】：2019-08-14 00:22:39
【问题描述】：

在我的用例中，我创建了 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 kafka-consumer-api apache-kafka-connect

【解决方案1】：

问题在于 YAML 配置文件中的架构注册表 URL。通知unknown protocol错误

把它改成这个（注意我在 URL 行添加了http:// 协议），它应该可以工作：

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

【讨论】：

@mjuarez- 谢谢！它解决了这个问题。感谢您的快速回复！