kafka
-
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….
-
掌握实时数据流：使用Apache Flink消费Kafka数据
导读：使用Flink实时消费Kafka数据的案例是探索实时数据处理领域的绝佳方式。不仅非常实用，而且对于理解现代数据架构和流处理技术具有重要意义。 理解Flink和…
-
怎样查看kafka写数据送到topic是否成功
要查看 Kafka 写数据是否成功送到主题（topic），可以通过以下几种方法来进行确认： Kafka 生产者确认机制：Kafka 提供了生产者的确认机制，您可以在创建生产者时设置…
-
Kafka查看Topic和消息内容命令
Kafka是一个分布式流处理平台，用于高吞吐量、低延迟的数据传输。在使用Kafka时，我们经常需要查看已创建的Topic以及Topic中的消息内容。本文将介绍如何使用Kafka提供…
