我正在尝试使用融合平台社区和 ksql 无头模式构建警报流应用程序。我的应用程序流程是我向带有主题的基本 ksql 流生成消息（具有阈值、alert_flag、device_id 等列的 json 格式）。ksql 的另一个查询过滤该流并生成警报到另一个表并将警报流发布到另一个主题。现在我想通过 kafkacat 或无论如何更改第一个主题的特定 device_id 的阈值和标志数据。可能吗？
我正在尝试使用融合平台社区和 ksql 无头模式构建警报流应用程序。我的应用程序流程是我向带有主题的基本 ksql 流生成消息（具有阈值、alert_flag、device_id 等列的 json 格式）。ksql 的另一个查询过滤该流并生成警报到另一个表并将警报流发布到另一个主题。现在我想通过 kafkacat 或无论如何更改第一个主题的特定 device_id 的阈值和标志数据。可能吗？