apache-kafka - 将缓存值中的 JSON CDC 数据映射到 Ignite sqlline 瘦客户端表

Question

基本上，我正在尝试通过连接器将 CDC JSON 数据从 Kafka 主题发送到 Ignite Cache。出于转换目的，我想在 Ignite 的表视图中查找此 JSON 数据。如何映射这些 JSON 字段来点燃 SQLline 表的列？

Answer 1

如果我正确理解了您的问题，那应该很简单。为此可以利用 Java 类。您可以指定与您的 JSON 结构相对应的结构。连同额外的缓存配置 ( CacheConfiguration.setIndexedTypes(…​)) 属性，它将使其支持 SQL。