左岩 Fri, 28 Oct 2022 03:34:23 -0700
upsert kafka作为source时，消费不到kafka中的数据 通过flink sql 写了一个upsert kafka connector 的连接器，去读一个topic,读不到数据，但是普通kafka 连接器消费这个topic 就能读到，都是读的同一个topic，代码如下
