Looking for a simple KStreams implementation to help you convert your json schema-less records into Avro? Or maybe Parquet?

I think, there are quite a few articles out there that tell you how to produce Avro records for Kafka. However, I had a hard time finding a solution on how I could transform an existing Json record into Avro/Parquet.

Let’s see if I can help some of you find a solution to this problem. In this tutorial, I’ll be showing you how to create a Kafka Streams application in Java using SpringBoot. Using this application, you’ll be able to read…