我有一个从 Kafka 写入 JSON 数据对象并通过弹性 API 将该对象中的一些字段放入弹性搜索索引的过程。
我必须编写两条单独的消息——一条用于数据对象，另一条用于弹性搜索索引，它是数据对象的子集。
我的问题是：我能否扩充 JSON 元模型，以便仅从 Kafka 发布一种记录格式，其中包含完整数据对象和可索引字段，但只有可索引字段加载到弹性搜索中？然后我不必维护两个单独的进程并使它们保持同步，我只有一个进程和 JSON 记录。
我不是批量加载，所以我不能使用该工具使用的批量加载 API 和“索引”字段标记，如 JSON 批量加载 API 示例