kafka
-
【Kafka-Eagle】EFAK告警配置与实践
Kafka-Eagle是一个开源的Kafka集群监控与告警系统，可以帮助用户实现对Kafka集群的实时监控、性能指标收集以及异常告警等功能。下面是关于Kafka-Eagle的告警配…
-
Kafka是什么，以及如何使用SpringBoot对接Kafka
系列文章目录 上手第一关，手把手教你安装kafka与可视化工具kafka-eagle 架构必备能力——kafka的选型对比及应用场景 Kafka存取原理与实现分析，打破面试难关 防…
-
Kafka概论
前言 任何消息中间件，除了基础组件架构外，核心特性无非三个，消息可靠性、消息模型、吞吐量，本文要聊的正是这些东西，其余诸如API、下载安装、集群搭建等都是死的，而且会随着版本的变动…
-
59、Flink CEP – Flink的复杂事件处理介绍及示例（2）- 模式API
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点，并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
-
Kafka消费者常用超时时间配置
https://blog.csdn.net/BHSZZY/article/details/126757295 //心跳超时时间（session超时时间）增加成25秒（之前项目设置了…
-
kafka日志文件详解及生产常见问题总结
一、kafka的log日志梳理 日志文件是kafka根目录下的config/server.properties文件，配置log.dirs=/usr/local/kafka/kafk…
-
kafka常用命令
文章目录 一、KAFKA启停命令 1. 前台启动 2. 后台启动 3. 停止命令 二、Topic 相关命令 2.1. 创建 Topic 2.2. 查询 Topic 列表 2.3. …
-
深入浅出理解kafka —- 万字总结
1.Kafka简介 Kafka 本质上是一个 MQ（Message Queue），使用消息队列的优点： 解耦：允许独立的扩展或修改队列两边的处理过程。可恢复性：即使一个处理消息的进…
-
kafka消费者程序日志报错Offset commit failed问题研究
生产环境偶尔会遇到kafka消费者程序日志报错的问题 截取主要日志如下： 2023-10-02 19:35:28.554 {trace: d7f97f70dd693e3d} ERR…
-
Kafka可视化管理工具kafka-manager部署安装和使用
一、kafka-manager 简介 为了简化开发者和服务工程师维护Kafka集群的工作，yahoo构建了一个叫做Kafka管理器的基于Web工具，叫做 Kafka Manager…
-
Spark与Kafka的集成与流数据处理
Apache Spark和Apache Kafka是大数据领域中非常流行的工具，用于数据处理和流数据处理。本文将深入探讨如何在Spark中集成Kafka，并演示如何进行流数据处理。…
-
java 集成kafka（支持单条消费和批量消费）
1、下载安装zk，kafka…（大把教程，不在这里过多阐述） 2、引入pom org.springframework.kafka spring-kafka 3、Kafk…
-
springboot 开启和关闭kafka消费
关闭kafka自动消费 配置自定义容器工厂 import org.springframework.beans.factory.annotation.Autowired; impor…
-
58、Flink维表的实战-6种实现方式维表的join
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点，并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
-
分布式 – 消息队列Kafka：Kafka 消费者消费位移的提交方式
文章目录 1. 自动提交消费位移 2. 自动提交消费位移存在的问题？ 3. 手动提交消费位移 1. 同步提交消费位移 2. 异步提交消费位移 3. 同步和异步组合提交消费位移 4….
