kafka
-
【flink番外篇】15、Flink维表实战之6种实现方式-初始化的静态数据
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点，并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
-
使用 Kafka 和 CDC 将数据从 MongoDB Atlas 流式传输到 SingleStore Kai
SingleStore 提供了变更数据捕获 (CDC) 解决方案，可将数据从 MongoDB 流式传输到 SingleStore Kai。在本文中，我们将了解如何将 Apache …
-
Zookeeper与Kafka集成与应用
1.背景介绍 Zookeeper和Kafka都是Apache基金会所开发的开源项目，它们在分布式系统中发挥着重要作用。Zookeeper是一个高性能的分布式协调服务，用于实现分布式…
-
Kafka 社区KIP-382中文译文（MirrorMaker2/集群复制/高可用/灾难恢复）
原文地址：KIP-382: MirrorMaker 2.0 – Apache Kafka – Apache Software Foundation 译者：对…
-
Kafka的分区和副本机制
Kafka的分区和副本机制是分布式消息系统中的重要概念，它们在数据一致性和容错方面起到了关键作用。下面我将详细介绍这两个机制的工作原理和底层实现思路，并通过Java源码示例和分析来…
-
Kafka高级
Kafka高级 目录 概述 需求： 设计思路 实现思路分析 Kafka高级_工作流程 Kafka高级_文件存储 参考资料和推荐阅读 Survive by day and devel…
-
SparkStreaming与Kafka整合
1.3 SparkStreaming与Kafka整合 1.3.1 整合简述 kafka是做消息的缓存，数据和业务隔离操作的消息队列，而sparkstreaming是一款准实时流式计…
-
ClickHouse Kafka 引擎教程
如果您刚开始并且第一次设置 Kafka 和 ClickHouse 需要帮助怎么办？这篇文章也许会提供下帮助。 我们将通过一个端到端示例，使用 Kafka 引擎将数据从 Kafka …
-
阿里技术官亲笔：Kafka限量笔记，一本书掌握Kafka的精髓
前言 分布式，堪称程序员江湖中的一把利器，无论面试还是职场，皆是不可或缺的技能。而Kafka，这款分布式发布订阅消息队列的璀璨明珠，其魅力之强大，无与伦比。对于Kafka的奥秘，我…
-
分布式事务完美解决方案：消息中间件（kafka）+ 本地事物 + 消息校对
前言 分布式事务是要保证多个服务下的多个数据库操作的一致性。分布式事务常见解决方案有：二阶段、三阶段和TCC实现强一致性事务，其实还有一种广为人知的方案就是利用消息队列来实现分布式…
-
springboot、spring-kafka、kafka-client的版本对应关系
在使用springboot集成kafka的时候需要注意springboot版本、引用的依赖spring-kafka版本和kafka中间件版本的对应关系，否则可能会因为版本不兼容导致…
-
Kafka事务是怎么实现的？Kafka事务消息原理详解（文末送书）
目录 一、Kafka事务性消息 1.1 介绍Kafka事务性消息 1.2 事务性消息的应用场景 1.3 Kafka事务性消息的优势 二、Kafka事务性消息的使用 2.1 配置Ka…
-
SpringBoot 集成 Kafka (SSL证书)
目录 1.SSL证书 2.全局配置 3.Producer配置 4.Consumer配置 5.运行异常汇总 1.SSL证书 使用特定的SSL证书才可以进行访问，可用于多个项目间中转…
-
flink 从kafka读取数据报错
报错: Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartB…
-
38、Flink 的CDC 格式：canal部署以及示例
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点，并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
