在Kafka KStream中查找第一个事件

Question

是否有任何方法只能为KStream中的对应键找到第一个事件？我不想保持单独的状态来跟踪第一个事件是否已到达给定密钥。

Answer 1

我会为此使用普通消费者。只需扫描主题以查找您感兴趣的键，然后在看到它时就停止消费