我有不止一个主题，每个主题的信息都有不同的行为。所以我必须以不同的方式对待每一条信息。所以我把信息和它的主题和Kafka流区分开来。有没有解决这个问题的方法，我希望以代码段为例。谢谢你的建议。