我需要构建一个应用程序，该应用程序从Kafka获取数据，将数据持久保存到某些数据库中，并将转换后的数据发送到另一个Kafka主题。
就我而言，我需要解析从Kafka收到的消息。数据将来自不同的设备和提要，因此它们将具有不同的架构。因此，我需要能够在运行时使用消息元数据创建键空间，并使用在运行时接收到的模式插入该键空间。
我不知道Spring数据Cassandra是否能够做到这一点。就像某种动态模型而不是固定模式一样，因此我可以使用包含键值对的映射，而不是固定域类。
谢谢
我不确定您要问的是什么，但是您可以定义保存Map类型的实体/表的属性/字段，以便可以保留从Kafka接收到的任何数据结构。
如果这对您有用，请告诉我，我将给出一个完整的示例进行设置。