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
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
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
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 ,
Please clarify where you are seeing this error. Is this an error you are seeing with Logstash?
What specifically do you want help with?
© 2020. All Rights Reserved - Elasticsearch
Apache, Apache Lucene, Apache Hadoop, Hadoop, HDFS and the yellow elephant logo are trademarks of the Apache Software Foundation in the United States and/or other countries.