kafka
-
Kafka（四）【Kafka 消费者】
目录 前言 Kafka 消费者 1、消费方式 2、消费者工作流程 2.1、消费者总体工作流程 2.2、消费者组原理 2.2.1、消费者组 2.2.2、消费者组初始化流程 2.3、消…
-
浅谈Kafka流控制与监控指标
Kafka 流控制与监控指标 Apache Kafka 是一个高度可扩展的、分布式的流处理平台，广泛应用于大数据和实时数据处理场景。为了确保 Kafka 集群的稳定性和性能，了解 …
-
Flink系列之：Upsert Kafka SQL 连接器
Flink系列之：Upsert Kafka SQL 连接器 一、Upsert Kafka SQL 连接器 二、依赖 三、完整示例 四、可用元数据 五、键和值格式 六、主键约束 七、…
-
认识kafka
认识KafKa 1.什么是KafKa： kafka是一种高吞吐量的分布式发布订阅消息消息队列，有如下特性： 可扩展性：Kafka可以处理大规模的数据流，并支持高并发的生产和消费操作…
-
消息中间件：Kafka
(1)Zookeeper安装 https://downloads.apache.org/zookeeper/ （1）更新系统的包管理器 sudo yum update （2）安装J…
-
【flink番外篇】9、Flink Table API 支持的操作示例（2）-完整版
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点，并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
-
第三章 Spring Boot 整合 Kafka消息队列 消息者
系列文章目录 第一章 Kafka 配置部署及SASL_PLAINTEXT安全认证 第二章 Spring Boot 整合 Kafka消息队列 生产者 第三章 Spring Bo…
-
查漏补缺，Kafka 核心知识，总有一个拨动你的心弦
说说你对kafka的理解 kafka是一个流式数据处理平台，他具有消息系统的能力，也有实时流式数据处理分析能力，只是我们更多的偏向于把他当做消息队列系统来使用。 如果说按照容易理解…
-
59、Flink CEP – Flink的复杂事件处理介绍及示例（4）- 延迟数据处理和三个实际应用示例
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点，并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
-
Flink流批一体计算（23）：Flink SQL之多流kafka写入多个mysql sink
目录 1. 准备工作 生成数据 创建数据表 2. 创建数据表 创建数据源表 创建数据目标表 3. 计算 WITH子句 1. 准备工作 生成数据 source kafka json …
-
自定义kafka客户端消费topic
文章目录 自定义kafka客户端消费topic 结论 1 背景 2 spring集成2.1.8.RELEASE版本不支持autoStartup属性 3 自定义kafka客户端消费t…
-
kafka如何避免消息重复消费
Kafka 避免消息重复消费通常依赖于以下策略和机制： 1. Consumer Group ID Kafka使用Consumer Group ID来跟踪每个消费者所读取的消息。确保…
-
一百七十二、Flume——Flume采集Kafka数据写入HDFS中（亲测有效、附截图）
一、目的 作为日志采集工具Flume，它在项目中最常见的就是采集Kafka中的数据然后写入HDFS或者HBase中，这里就是用flume采集Kafka的数据导入HDFS中 二、各工…
-
【kafka】Java客户端代码demo：自动异步提交、手动同步提交及提交颗粒度、动态负载均衡
一，代码及配置项介绍 kafka版本为3.6，部署在3台linux上。 maven依赖如下： org.apache.kafka kafka_2.13 3.6.0 生产者、消费者和t…
-
Kafka实战：消费指定时间范围内的Kafka Topic数据
Kafka实战：消费指定时间范围内的Kafka Topic数据 在大数据领域，Kafka是一个广泛使用的分布式流数据平台。它提供了高吞吐量、可扩展性和容错性，使得实时数据流处理变得…
