相关疑难解决方法(0)

是否可以从 kafka 消息中获取消息密钥的最新值

假设我对同一个消息键有不同的值。

例如:

{
userid: 1,
email: user123@xyz.com }

{
userid: 1,
email: user456@xyz.com }

{
userid: 1,
email: user789@xyz.com }
Run Code Online (Sandbox Code Playgroud)

在上面的这种情况下,我只想要用户更新的最新值,即“user789@xyz.com”。

我的 kafka 流应该只给我第三个值,而不是前两个值。

apache-kafka apache-kafka-streams spring-kafka confluent-platform ksqldb

3
推荐指数
1
解决办法
1886
查看次数