Go app used in part 2 of the blog Consuming and Storing Kafka Messages in Snowflake Using Kafka Connect.
The purpose of the app is to read json files with sample messages from the data/ directory, serialize them with both Protobuf and Avro serialization formats using the schemas from Confluent Schema Registry and publish them to Kafka hosted in Kubernetes using Koperator.
