ApacheKafka—kafkacat是否可以修改或更新主题的消息?

jm81lzqq  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(351)

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

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题