目标是使用来自Kafka的不同类型的消息。消息采用avro格式。每个消息都可以表示为java实体。有几种类型的消息具有特定的字段。输出应该是avro文件，并按字段过滤消息。
我试着使用java反射，但我不确定它是否是最好的和稳定的方法。
谢谢你的建议。