converting Avro data format into Json in java

[#1]

Hii,

Please can help me, By using kafkaStreaming api i get the avro data from kafka then i will try to convert avro data format into json then push into kafka,

[#2]

You can use either ConvertRecord or ConvertAvroToJSON to convert your incoming Avro data to JSON. If the incoming Avro files do not have a schema embedded in them, then you will have to provide it, either to an AvroReader (for ConvertRecord) or the "Avro schema" property (for ConvertAvroToJSON).

[#3]

Schema schema = ....

@SuppressWarnings("static-access") Decoder binaryDecoder = DecoderFactory.get().get().binaryDecoder(value.toString().getBytes(), null); System.out.println("test"); @SuppressWarnings("rawtypes") GenericDatumReader<GenericRecord> payloadReader = new SpecificDatumReader<GenericRecord>(schema); System.out.println("test1" + binaryDecoder.toString().length()+ "test"); GenericRecord recode = null; recode = payloadReader.read(recode, binaryDecoder); System.out.println("test2");