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-string-topic
test-output --output-avro-topic test-avro-output --output-subject --bootstrap.servers
localhost:9092 --schema-registry-url http://localhost:8081 --group.id myconsumer