You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by kcz <57...@qq.com> on 2020/06/10 12:10:56 UTC

回复:kafka相关问题

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





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



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