public class TestAvroConsumerConfluent
extends Object
A simple example that shows how to read from and write to Kafka with Confluent Schema Registry.
This will read AVRO messages from the input topic, parse them into a POJO type via checking the Schema by calling Schema registry.
Then this example publish the POJO type to kafka by converting the POJO to AVRO and verifying the schema.
--input-topic test-input --output-topic test-output --bootstrap.servers localhost:9092 --zookeeper.connect localhost:2181 --schema-registry-url http://localhost:8081 --group.id myconsumer