Apache Flink 漫谈系列(15) - DataStream Connectors之Kafka
发布时间:2019-01-19 12:08:17 所属栏目:教程 来源:孙金城
导读:一、聊什么 为了满意本系列读者的需求,我先先容一下Kafka在Apache Flink中的行使。以是本篇以一个简朴的示例,向各人先容在Apache Flink中怎样行使Kafka。 二、Kafka 简介 Apache Kafka是一个漫衍式宣布-订阅动静转达体系。 它最初由LinkedIn公司开拓,Li
本篇重点是向各人先容Kafka如安在Flink中举办应用,开篇先容了Kafka的简朴安装和收动员静的呼吁演示,然后以一个简朴的数据提取和一个Event-time的窗口示例让各人直观的感觉如安在Apache Flink中行使Kafka。愿先容的内容对您有所辅佐! 关于点赞和评述 本系列文章不免有许多缺陷和不敷,真诚但愿读者对有收成的篇章给以点赞勉励,对有不敷的篇章给以反馈和提议,先行感激各人! 作者:孙金城,混名 金竹,今朝就职于阿里巴巴,自2015年以来一向投入于基于Apache Flink的阿里巴巴计较平台Blink的计划研发事变。 【本文为51CTO专栏作者“金竹”原创稿件,转载请接洽原作者】 戳这里,看该作者更多好文 (编辑:湖南网) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |