Flink的sink实战之二：kafka
欢迎访问我的GitHub https://github.com/zq2599/blog_demos 内容：所有原创文章分类汇总及配套源码，涉及Java、Docker、Kubernetes、DevOPS等； 本篇概览 本文是《Flink的sink实战》系列的第二篇，前文《Flink的sink ...
原文：Flink-Kafka-Connector Flink结合Kafka实战
戳更多文章： Flink入门 本地环境搭建 amp 构建第一个Flink应用 DataSet API DataSteam API 集群部署 分布式缓存 重启策略 Flink中的窗口 Flink中的Time Flink时间戳和水印 Broadcast广播变量 FlinkTable amp SQL Flink实战项目实时热销排行 Flink写入RedisSink Flink消费Kafka写入Mysql ...
2019-04-27 19:47 0 11421 推荐指数：
相关推荐
Flink与Spark Streaming在与kafka结合的区别！
本文主要是想聊聊flink与kafka结合。当然，单纯的介绍flink与kafka的结合呢，比较单调，也没有可对比性，所以的准备顺便帮大家简单回顾一下Spark Streaming与kafka的结合。 看懂本文的前提是首先要熟悉kafka，然后了解spark Streaming的运行原理 ...
Flink kafka connector 端到端精确一次测试
官网博客中： Apache Flink中的端到端精确一次处理概述 对Flink 端到端精确一次处理和两段提交的原理，有详尽的描述 这里要写的是，关于 Flink kafka 端到端精确一次的测试 之前就大概测试过相应内容，应该是测试失败了的，只得到了至少一次的结果（之前的关注点不在 ...
flink-connector-kafka consumer checkpoint源码分析
转发请注明原创地址：http://www.cnblogs.com/dongxiao-yang/p/7700600.html 《flink-connector-kafka consumer的topic分区分配源码》一文提到了在flink-connector-kafka的consumer ...
flink-1.12.0 upsert-kafka connector demo
参考官网： https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/dev/table/connectors/kafka.htmlhttps://ci.apache.org/projects/flink ...
flink-connector-kafka consumer的topic分区分配源码
转载请注明原创地址 http://www.cnblogs.com/dongxiao-yang/p/7200599.html flink官方提供了连接kafka的connector实现，由于调试的时候发现部分消费行为与预期不太一致，所以需要研究一下源码 ...
HBase2实战：HBase Flink和Kafka整合
1.概述 Apache官方发布HBase2已经有一段时间了，HBase2中包含了许多个Features，从官方JIRA来看，大约有4500+个ISSUES（查看地址），从版本上来看是一个非常大的版本了。本篇博客将为大家介绍HBase2的新特性，以及如何在实战中与Flink、Kafka等组件进行 ...
项目实战 从 0 到 1 学习之Flink（11）Flink 写入数据到 Kafka
前言 之前文章 《从0到1学习Flink》—— Flink 写入数据到 ElasticSearch 写了如何将 Kafka 中的数据存储到 ElasticSearch 中，里面其实就已经用到了 Flink 自带的 Kafka source connector ...