Flink CDC+Kafka 加速业务实时化

Kafka 物理存储机制

知识百科 • 数栈君发表了文章 • 0 个评论 • 224 次浏览 • 2024-11-04 13:56 • 来自相关话题

一、分区分配创建主题时，Kafka首先决定如何在broker之间分配分区。假设有6个broker，打算创建一个包含10个分区的主题。并且复制系数是3，相当于30个分区副本。在被分配到6个broker上时，要达到如下的目标：【1】在broker间平均分配分区副本... ...查看全部

Kafka延迟队列的实现方式

网友分享 • 数栈君发表了文章 • 0 个评论 • 1264 次浏览 • 2024-07-31 15:17 • 来自相关话题

在现代的分布式系统中，延迟队列是一种常见的解决方案，用于处理具有延迟要求的任务或消息。Apache Kafka是一个高性能、可扩展的分布式消息队列，可以作为延迟队列的基础设施。本文将介绍如何使用Kafka实现延迟队列，并提供详细的Java示例。什么是延迟队列？... ...查看全部

kafka如何保证消息不丢失

网友分享 • 数栈君发表了文章 • 0 个评论 • 317 次浏览 • 2024-07-24 14:21 • 来自相关话题

Kafka发送消息是异步发送的，所以我们不知道消息是否发送成功，所以会可能造成消息丢失。而且Kafka架构是由生产者-服务器端-消费者三种组成部分构成的。要保证消息不丢失，那么主要有三种解决方法。生产者(producer)端处理生产者默认发送消息代码如下：i... ...查看全部

kafkastream的集成和入门

网友分享 • 数栈君发表了文章 • 0 个评论 • 347 次浏览 • 2024-07-24 14:17 • 来自相关话题

kafkastream的介绍：Kafka Streams是一个开源的流处理库，用于构建实时数据流应用程序和微服务。它是Apache Kafka项目的一部分，是一种基于事件驱动的流处理解决方案。Kafka Streams提供了高级别的API，使开发人员能够以简单... ...查看全部

融合数据库生态：利用 EventBridge 构建 CDC 应用

知识百科 • 数栈君发表了文章 • 0 个评论 • 377 次浏览 • 2023-11-15 11:36 • 来自相关话题

Flink SQL CDC 实践以及一致性分析

知识百科 • 数栈君发表了文章 • 0 个评论 • 417 次浏览 • 2023-11-15 11:36 • 来自相关话题

多库多表场景下使用 Amazon EMR CDC 实时入湖最佳实践

知识百科 • 数栈君发表了文章 • 0 个评论 • 596 次浏览 • 2023-11-15 11:35 • 来自相关话题

在大数据时代，数据仓库已经成为企业进行数据分析和决策的重要工具。然而，随着业务的发展，数据量的增长，传统的ETL工具已经无法满足实时入湖的需求。为了解决这个问题，Amazon EMR (Elastic MapReduce) 提供了 Change Data Ca... ...查看全部

Flink CDC MongoDB Connector 的实现原理和使用实践

知识百科 • 数栈君发表了文章 • 0 个评论 • 426 次浏览 • 2023-11-15 11:35 • 来自相关话题

Flink CDC 系列 - 实时抽取 Oracle 数据，排雷和调优实践

知识百科 • 数栈君发表了文章 • 0 个评论 • 1406 次浏览 • 2023-11-15 11:34 • 来自相关话题

在现代数据处理领域，实现对数据库变更的实时捕捉与分析已成为一个迫切需求。Apache Flink 社区提供的 Change Data Capture (CDC) 功能能够有效地满足这一需求。特别是在处理 Oracle 数据时，Flink CDC 提供了一套高效... ...查看全部

基于 SeaTunnel 构建 CDC 流式应用7 CDC提高触摸控制精度和可靠性

知识百科 • 数栈君发表了文章 • 0 个评论 • 441 次浏览 • 2023-11-15 11:34 • 来自相关话题

Kafka 物理存储机制

知识百科 • 数栈君发表了文章 • 0 个评论 • 224 次浏览 • 2024-11-04 13:56 • 来自相关话题

Kafka延迟队列的实现方式

网友分享 • 数栈君发表了文章 • 0 个评论 • 1264 次浏览 • 2024-07-31 15:17 • 来自相关话题

kafka如何保证消息不丢失

网友分享 • 数栈君发表了文章 • 0 个评论 • 317 次浏览 • 2024-07-24 14:21 • 来自相关话题

kafkastream的集成和入门

网友分享 • 数栈君发表了文章 • 0 个评论 • 347 次浏览 • 2024-07-24 14:17 • 来自相关话题

融合数据库生态：利用 EventBridge 构建 CDC 应用

知识百科 • 数栈君发表了文章 • 0 个评论 • 377 次浏览 • 2023-11-15 11:36 • 来自相关话题

Flink SQL CDC 实践以及一致性分析

知识百科 • 数栈君发表了文章 • 0 个评论 • 417 次浏览 • 2023-11-15 11:36 • 来自相关话题

多库多表场景下使用 Amazon EMR CDC 实时入湖最佳实践

知识百科 • 数栈君发表了文章 • 0 个评论 • 596 次浏览 • 2023-11-15 11:35 • 来自相关话题

Flink CDC MongoDB Connector 的实现原理和使用实践

知识百科 • 数栈君发表了文章 • 0 个评论 • 426 次浏览 • 2023-11-15 11:35 • 来自相关话题

Flink CDC 系列 - 实时抽取 Oracle 数据，排雷和调优实践

知识百科 • 数栈君发表了文章 • 0 个评论 • 1406 次浏览 • 2023-11-15 11:34 • 来自相关话题

基于 SeaTunnel 构建 CDC 流式应用7 CDC提高触摸控制精度和可靠性

知识百科 • 数栈君发表了文章 • 0 个评论 • 441 次浏览 • 2023-11-15 11:34 • 来自相关话题

更多...

Kafka 物理存储机制

Kafka延迟队列的实现方式

kafka如何保证消息不丢失

kafkastream的集成和入门

融合数据库生态：利用 EventBridge 构建 CDC 应用

Flink SQL CDC 实践以及一致性分析

多库多表场景下使用 Amazon EMR CDC 实时入湖最佳实践

Flink CDC MongoDB Connector 的实现原理和使用实践

Flink CDC 系列 - 实时抽取 Oracle 数据，排雷和调优实践

基于 SeaTunnel 构建 CDC 流式应用7 CDC提高触摸控制精度和可靠性

Kafka 物理存储机制

Kafka延迟队列的实现方式

kafka如何保证消息不丢失

kafkastream的集成和入门

融合数据库生态：利用 EventBridge 构建 CDC 应用

Flink SQL CDC 实践以及一致性分析

多库多表场景下使用 Amazon EMR CDC 实时入湖最佳实践

Flink CDC MongoDB Connector 的实现原理和使用实践

Flink CDC 系列 - 实时抽取 Oracle 数据，排雷和调优实践

基于 SeaTunnel 构建 CDC 流式应用7 CDC提高触摸控制精度和可靠性

话题描述

相关话题

1 人关注该话题