我正在尝试用融合平台社区&ksql无头模式构建一个警报流应用程序。我的应用程序流是我生成消息(json格式,其中包含像threshold、alert\u flag、device\u id等列)到一个带有主题的基本ksql流。ksql的另一个查询过滤该流并生成对另一个表的警报,并将警报流发布到另一个主题。现在我想通过kafkacat或其他方式更改第一个主题的secific device\u id的阈值和标志数据。有可能吗?
我正在尝试用融合平台社区&ksql无头模式构建一个警报流应用程序。我的应用程序流是我生成消息(json格式,其中包含像threshold、alert\u flag、device\u id等列)到一个带有主题的基本ksql流。ksql的另一个查询过滤该流并生成对另一个表的警报,并将警报流发布到另一个主题。现在我想通过kafkacat或其他方式更改第一个主题的secific device\u id的阈值和标志数据。有可能吗?
暂无答案!
目前还没有任何答案,快来回答吧!