我正在尝试实现我自己的Kafka主题ui。主题大多是avro类型，有些是string，有些是json。我使用的是org.apache.kafka.clients.consumer（2.5.0）。如果事件是avro编码的，那么将它们作为genericords使用是没有问题的。
现在，如果使用者无法读取记录，我将捕获异常并尝试用json编码解释事件，但我找到的所有示例都使用pojo转换json。
我的问题是我永远不知道事件有哪些编码，记录是否有密钥。
对如何解决这个问题有什么建议吗？