你好,可以检查一下 kafka 消息的 key 是否正确,key 如果为空 upsert-kafka source 无法正确输出数据。


> 2024年11月12日 11:36,Yanquan Lv <[email protected]> 写道:
> 
> 你好,你的 Kafka 的数据里有设置消息的键(key)值吗?
> Upsert-Kafka 依赖键进行更新、删除操作。
> 
> 
>> 2024年11月11日 22:30,高速缓存 <[email protected]> 写道:
>> 
>> upsert-kafka
> 

回复