你好，可以检查一下 kafka 消息的 key 是否正确，key 如果为空 upsert-kafka source 无法正确输出数据。
> 2024年11月12日 11:36，Yanquan Lv <decq12y...@gmail.com> 写道： > > 你好，你的 Kafka 的数据里有设置消息的键（key）值吗？ > Upsert-Kafka 依赖键进行更新、删除操作。 > > >> 2024年11月11日 22:30，高速缓存 <guoyu0...@foxmail.com> 写道： >> >> upsert-kafka >
