我正在尝试编写一个简单的工作流，在这个工作流中，我读取一个csv文件，将其转换为json，并根据json中存在的元素将特定的json对象路由到kafka主题。例如，我有两个json记录，其中一个是“env”：“prod”，另一个是“env”：“dev”。基于env，我希望特定的json记录转到特定的kafka主题。
我能够将csv转换为json。但是，我不确定如何从json记录中读取特定元素，然后进行路由。任何帮助都将不胜感激。如有可能，请详细说明。
谢谢