CODEWITHSUNDEEP
apache-kafkakafka-consumer-apiapache-kafka-connect
James Mark
James Mark

Reputation: 349

Kafka consumer is failing with Error deserializing Avro message with unknown protocol

In my use case, i had created JDBC kafka connector, pulled the data from oracle table and sucessfully pushed to kafka topic but when i try to read the messages from this kafka topic i get the deserialization issue as listed below.

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)

Upvotes: 2

Views: 8277

Answers (1)

mjuarez
mjuarez

Reputation: 16824

The problem is the schema registry URL in the YAML configuration file. Notice unknown protocol error

Change it to this (note I added the http:// protocol to the URL line), and it should work:

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

Upvotes: 7

Related Questions