keyBy 后的 getKey 函数调用了两次

[Lei Wang]

接收 kafka 的数据后 keyBy， sinkTest 中什么也没做。

env.addSource(consumer).keyBy(new KeySelector<String, String>() {
    @Override
    public String getKey(String value) throws Exception {
        System.out.println(value);
        return value;
    }
}).addSink(new SinkTest(1));


我自己做测试，每发送一条消息console 会打印两次，也就是 System.out.println(value) 被调用了两次。

为什么会这样呢，哪个地方还调用了 getKey 这个函数呢？


谢谢，

王磊