假设我对同一个消息键有不同的值。
例如:
{
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