kafka
-
一碰就头疼的 Kafka 消息重复问题,立马解决!
一碰就头疼的 Kafka 消息重复问题,立马解决! 一、前言 整理下消息重复的几个场景: Kafka 幂等性 Producer Kafka 事务 消费端幂等 二、案例:Kafka …
-
Kafka——管理Kafka(命令行工具)详解
目录 管理Kafka 1、主题操作(kafka-topic.sh) 1.1、创建主题(–create) 1.2、增加分区(–alter) 1.3、减少分区数…
-
java使用kafka-clients集成0.10.0.0版本kafka(一)
一.版本兼容的问题 因为某个功能需要对接的kafka是一个上古版本0.10.0.0,公司项目又是springcloud项目,导致版本兼容性的问题很头大 1.kafka的版本号 下载…
-
Kafka与Spring Boot等应用框架的集成及消息驱动模型
Kafka与Spring Boot等应用框架的集成及消息驱动模型 在当今的高效分布式系统中,Kafka 是一个不可或缺的组件,它用于处理大规模的实时数据流。Kafka 与 Spri…
-
Kafka新特性:引领大数据时代,助力企业实时数据处理与分析
Kafka新特性 概述 新增 改进: 重点功能 分层存储 集群配置 优点 支持 不支持 主页传送门:📀 传送 概述 上个月kafka刚刚更新了新版本3.6.0,下面…
-
Kafka中的fetch-min-size、fetch-max-wait和request.timeout.ms配置
当前kafka的版本为2.8.11,Spring Boot的版本为2.7.6,在pom.xml中引入下述依赖: org.springframework.kafka spring-…
-
kafka学习笔记
“我翻开招聘APP一查,这上面没有功能测试,歪歪斜斜的每页上都写着“大数据”几个字。我横竖睡不着,仔细看了半夜,才从字缝里看出字来,满本都写着两个字是“kafka”!” 那么让我们…
-
一个基于Kafka客户端封装的工具,Kafka开发效率神器
GitHub源码https://github.com/zhangchuangiie/SimpleKafka SimpleKafka(Kafka客户端封装工具类) 一个基于Kafka…
-
Flink实现同时消费多个kafka topic,并输出到多个topic
Flink实现同时消费多个kafka topic,并输出到多个topic 1.说明 2.依赖引用 3. 方案一:适用于==sink topic==存在跨集群等kafka生产者配置信…
-
黑马头条–day11-kafkaStream热点文章实时计算
目录 一.定时计算与实时计算 二. 实时流式计算 1.概念 2. 应用场景 3.技术方案选型 三. Kafka Stream 1 概述 2.Kafka Streams的关键概念 3…
-
Kafka 监听器详解
Kafka 监听器详解 Kafka Assistant 是一款 Kafka GUI 管理工具——管理Broker,Topic,Group、查看消费详情、监控服务器状态、支持多种消息…
-
windows/linux 安装zookeeper + Kafka (含自启动)运行教学
首先我们来花两分钟了解一下: 什么是zookeeper? 什么是kafka? 为什么kafka依赖zookeeper和javaSDK? Zookeeper 和 Kafka 都是 A…
-
kafka系列:windows安装kafka
文章目录 一、jdk安装 二、安装zookeeper 1、下载并解压zookeeper 2、修改zoo.cfg配置文件 3、添加zookeeper环境变量 4、启动zookeepe…
-
【flink番外篇】22、通过 Table API 和 SQL Client 操作 Catalog 示例
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点,并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
-
Kafka 简介
目录 1、概念介绍 Kafka 由来 ZooKeeper Kafka 特性 Kafka 使用场景 Kafka 复制备份 2、Kafka 架构 Broker Topic Produ…
