Hello everyone,
i have adapted the source (#34) and at first everything works fine. With smaller examples there are no problems and the json files are converted to avro and written to the topic. Great !!
When I wanted to test the data for the upcoming project the producer (kafka-serdes-avro-console-producer) runs without errors but the avro message does not reach the topic and no error message is created.
I didn't notice anything, because the json is converted correctly into the avro and no error occurs during the producing process. This error is easy to reproduce and I would be glad if someone of you can confirm this.
I attach the schema file here (fullschema)
I attach the Json message here (jsonmessage)
I wrote the avro converted from the Json into a file for control purposes and append it to the file (avromessage)
For a short confirmation I would be very grateful for a solution I would throw a round pizza ;)
Hello everyone, i have adapted the source (#34) and at first everything works fine. With smaller examples there are no problems and the json files are converted to avro and written to the topic. Great !! When I wanted to test the data for the upcoming project the producer (kafka-serdes-avro-console-producer) runs without errors but the avro message does not reach the topic and no error message is created. I didn't notice anything, because the json is converted correctly into the avro and no error occurs during the producing process. This error is easy to reproduce and I would be glad if someone of you can confirm this.
My environment: confluent-5.5.1 libserdes
run ./kafka-serdes-avro-console-producer -b localhost:9092 -t topic_01 -s schema_02 -S "$(cat fullschema.json)"
I attach the schema file here (fullschema) I attach the Json message here (jsonmessage) I wrote the avro converted from the Json into a file for control purposes and append it to the file (avromessage)
For a short confirmation I would be very grateful for a solution I would throw a round pizza ;)
Thanks again and see you soon regards Dusan
fullschema.txt jsonmessage.txt avromessage.txt
fullschema.txt