Avro data format convert into json format


(vamsi) #1

Hiii,

The data comming from kafka by using kafkastream s ,It s avro format then i will try to convert json but it s not work,Please can help me


(Andrew Kroh) #2

You can pull Avro data from Kafka using Logstash.

input {
  kafka {
    codec => avro {
        schema_uri => "/tmp/schema.avsc"
    }
  }
}

Reference: https://www.elastic.co/guide/en/logstash/current/plugins-codecs-avro.html


(vamsi) #3

Yeah but affter getting the avro data from kafka i need to convert json then again push into kafka,
i have trying converting json but when i reading binary (avro) data by using GenaricDatumReader it throws ArrayIndexOutOf BoudnceException,

Thank you ,


(Andrew Kroh) #4

Please clarify where you are seeing this error. Is this an error you are seeing with Logstash?

What specifically do you want help with?


(system) #5

This topic was automatically closed after 28 days. New replies are no longer allowed.