kafka
-
一文读懂kafka消息丢失问题和解决方案
前言 今天分享一下kafka的消息丢失问题，kafka的消息丢失是一个很值得关注的问题，根据消息的重要性，消息丢失的严重性也会进行放大，如何从最大程度上保证消息不丢失，要从生产者，…
-
【Flink-Kafka-To-Mysql】使用 Flink 实现 Kafka 数据写入 Mysql（根据对应操作类型进行增、删、改操作）
【Flink-Kafka-To-Mysql】使用 Flink 实现 Kafka 数据写入 Mysql（根据对应操作类型进行增、删、改操作） 1）导入依赖 2）resources 2…
-
IDEA中运行Dinky0.7.5之KAFKA数据源调试问题解决过程
IDEA中运行Dinky0.7.5之KAFKA数据源调试问题解决过程 1. 首次代码编译 本文所使用的IDEA版本信息如下： IntelliJ IDEA 2023.1.3 (C…
-
Windows中Zookeeper与kafka的安装配置
一、Zookeeper安装与使用 1.安装包下载 直接在官网下载即可Apache ZooKeeper。 下载后直接解压到本地即可。 2.环境配置 1> 在目录中下增加data…
-
Spring for Apache Kafka Deep Dive – Part 1: Error Handling, Message Conversion and Transaction Suppo
Following on from How to Work with Apache Kafka in Your Spring Boot Application, which sho…
-
一碰就头疼的 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…
