{"version":"1.0","provider_name":"Blog - Silicon Cloud","provider_url":"https:\/\/www.silicloud.com\/blog","author_name":"Emily Johnson","author_url":"https:\/\/www.silicloud.com\/blog\/author\/emilyjohnson\/","title":"How can Flink deduplicate data in Kafka?","type":"rich","width":600,"height":338,"html":"<blockquote class=\"wp-embedded-content\" data-secret=\"PnHOIYBGH5\"><a href=\"https:\/\/www.silicloud.com\/blog\/how-can-flink-deduplicate-data-in-kafka\/\">How can Flink deduplicate data in Kafka?<\/a><\/blockquote><iframe sandbox=\"allow-scripts\" security=\"restricted\" src=\"https:\/\/www.silicloud.com\/blog\/how-can-flink-deduplicate-data-in-kafka\/embed\/#?secret=PnHOIYBGH5\" width=\"600\" height=\"338\" title=\"&#8220;How can Flink deduplicate data in Kafka?&#8221; &#8212; Blog - Silicon Cloud\" data-secret=\"PnHOIYBGH5\" frameborder=\"0\" marginwidth=\"0\" marginheight=\"0\" scrolling=\"no\" class=\"wp-embedded-content\"><\/iframe><script type=\"text\/javascript\">\n\/* <![CDATA[ *\/\n\/*! This file is auto-generated *\/\n!function(d,l){\"use strict\";l.querySelector&&d.addEventListener&&\"undefined\"!=typeof URL&&(d.wp=d.wp||{},d.wp.receiveEmbedMessage||(d.wp.receiveEmbedMessage=function(e){var t=e.data;if((t||t.secret||t.message||t.value)&&!\/[^a-zA-Z0-9]\/.test(t.secret)){for(var s,r,n,a=l.querySelectorAll('iframe[data-secret=\"'+t.secret+'\"]'),o=l.querySelectorAll('blockquote[data-secret=\"'+t.secret+'\"]'),c=new RegExp(\"^https?:$\",\"i\"),i=0;i<o.length;i++)o[i].style.display=\"none\";for(i=0;i<a.length;i++)s=a[i],e.source===s.contentWindow&&(s.removeAttribute(\"style\"),\"height\"===t.message?(1e3<(r=parseInt(t.value,10))?r=1e3:~~r<200&&(r=200),s.height=r):\"link\"===t.message&&(r=new URL(s.getAttribute(\"src\")),n=new URL(t.value),c.test(n.protocol))&&n.host===r.host&&l.activeElement===s&&(d.top.location.href=t.value))}},d.addEventListener(\"message\",d.wp.receiveEmbedMessage,!1),l.addEventListener(\"DOMContentLoaded\",function(){for(var e,t,s=l.querySelectorAll(\"iframe.wp-embedded-content\"),r=0;r<s.length;r++)(t=(e=s[r]).getAttribute(\"data-secret\"))||(t=Math.random().toString(36).substring(2,12),e.src+=\"#?secret=\"+t,e.setAttribute(\"data-secret\",t)),e.contentWindow.postMessage({message:\"ready\",secret:t},\"*\")},!1)))}(window,document);\n\/\/# sourceURL=https:\/\/www.silicloud.com\/blog\/wp-includes\/js\/wp-embed.min.js\n\/* ]]> *\/\n<\/script>\n","description":"In Flink, deduplicating data from Kafka can be achieved using the following methods: Organize by key decrease combine To bend or crease something to form pleats or layers. DataStream&lt;MyData&gt; stream = env.addSource(new FlinkKafkaConsumer&lt;&gt;(...)); DataStream&lt;MyData&gt; deduplicatedStream = stream .keyBy(data -&gt; data.getId()) \/\/ \u6309\u7167 id \u5b57\u6bb5\u8fdb\u884c\u5206\u7ec4 .reduce((data1, data2) -&gt; data1); \/\/ \u4f7f\u7528 reduce \u64cd\u4f5c\u7b26\u5c06\u76f8\u540c id \u7684\u6570\u636e\u53bb\u91cd group [&hellip;]"}