你这个表达,实时kafka的一条记录,你要最新的那个是吧,你最新的判断标准是什么?根据什么特性来,表达清楚一点哇。





------------------ 原始邮件 ------------------
发件人: 小学生 <201782...@qq.com&gt;
发送时间: 2020年6月10日 18:15
收件人: user-zh <user-zh@flink.apache.org&gt;
主题: 回复:kafka相关问题



业务场景是我需要实时的kafka一条消息记录,从里边取一个字段的值,根据这个值去mysql的表中去筛选出这个值下的记录数,类似与where的条件,所以每次我只希望能得到kafka实时消息里的记录值。

回复