我正在本地测试部署到docker的siddhi工具5.1.2中的模式。
我有7个事件的Kafka主题,可以通过其他监控工具看到。我定义了一个源并将所有事件存储到rdbms。查询非常简单: from my_stream select * insert into my_table;
由于某种原因,在db中我看到了17条记录,实际上是7对相同的事件。没有特殊配置,没有错误。
我试过了 down && up
docker与工具组合,更改了源的组id。有时更改组id会有所帮助,但问题又回来了。
我预计只有7个事件被读取并存储到数据库中。
为什么会产生重复的事件?
暂无答案!
目前还没有任何答案,快来回答吧!