fonzieQi

I listen to kafka messages. Kafka messages are in avro format, and errors are reported when running. ``` avro-logstash_1 | [2019-12-13T15:38:13,239][INFO ][org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] [Consumer clientId=kafka_avro_dev-2, groupId=kafka_avro_dev] Setting newly assigned partitions: avro-logstash_1...