摘要：本文基于Flink1.9.0和Kafka2.3版本，对Flinkkafka端到端ExactlyOnce进行分析及 notifyCheckpointComplete顺序，主要内容分为以下两部分：1.Flinkkafka两阶段提交源码分析TwoPhaseCommitSinkFuncti

FlinkKafka整合实例1.使用工具IntelligIDEA新建一个maven项目，为项目命名为kafka01。2.我的pom.xml文件配置如下。<?xmlversion"1.0"encoding"UTF8"?<projectxmlns"http://maven.apache.org/POM/4

Kafka快速入门（十一）——RdKafka源码分析一、RdKafkaC源码分析1、KafkaOP队列RdKafka将与KafkaBroke的交互、内部实现的操作都封装成Operator结构，然后放入OP处理队列里统一处理。KafkaOP队列是线

配置参考然后不废话，直接贴最终的关键配置:想实现消息队列中保存2小时的消息，那么配置应该像这样:log.roll.hours1log.retention.hours2log.segment.delete.delay.ms0Kafka日志存储机制分析

!(https://oscimg.oschina.net/oscnet/c44a8479ca04449e89ed30c37058117a.jpg)_来源：_blog.csdn.net/qq\_29676623/article/details/85108070为什么使用消息队列？消息队列的优点和缺点？kafka、activemq

点击上方“Java知音”，选择“置顶公众号”技术文章第一时间送达！作者：haolujuncnblogs.com/haolujun/p/9632835.html前言开源社区有好多优秀的队列中间件，比如RabbitMQ和Kafka，每个队列都貌似有其特性，在进行工程选择时，往往眼花缭乱，不知所措。对于Rabb

项目概述CDN热门分发网络，日志数据分析，日志数据内容包括aliyunCNE17/Jul/2018:17:07:500800223.104.18.110v2.go2yd.com17168接入的数据类型就是日志离线：FlumeHDFS实时: Kafka

一、背景       在springboot实际项目开发中，kafka可能需要消费多个不同服务器地址的数据，这时懂得如何进行配置就显得非常必要了。二、配置      1、KafkaConfig.java配置packagecom.lantaiyuan.ebu

点击上方蓝色字体，选择“设为星标”回复”资源“获取更多资源!(https://oscimg.oschina.net/oscnet/0ec2bb42027f450987603b5e78c59064.jpg)!(https://oscimg.oschina.net/oscnet/7c29b29e4a8349f1

在这里我会给大家展示Kafka它的高性能是如何设计的，大家也可以学习相关方法论将其利用在实际项目中，也许下一个顶级项目就在各位的代码中产生了。