ApacheKafka流处理器没有先正确处理消息,然后对其进行乘法

muk1a3rh  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(397)

我有两个主题由streamprocessor连接:
主题->流程->主题
我将第一条消息发送到主题a,主题a在那里被记录下来,然后通过processora处理,它最终进入topicb。

1的行为是重复的,但并不是以一种不变的模式

有什么办法可以解决这个问题吗?

pkwftd7m

pkwftd7m1#

看来已经解决了。
问题是在类示例中存储局部变量的副作用,这会导致一些奇怪的事情和不可预测的(不变量)!

相关问题