- 【项目实战】Kafka 重平衡 Consumer Group Rebalance 机制
......
- linux系统，kafka常用命令
kafka版本过高所致，2.2+=的版本，已经不需要依赖zookeeper来查看/创建topic，新版本使用--bootstrap-server替换老版本的--zookeeper-server。[root@kwephis1160698bin]#./kafka-topics.sh--list--zookeeperlocalhost:2181Exceptioninthread"main"joptsimple.Unrecognized......
- windows10下安装kafka
安装JDK下载地址：www.oracle.com/java/technologies/downloads我是装的java17.0.8X64Installer，不是javer所以不懂区别。下好以后开始安装，一路下一步就是了，安装目录装在的D盘 D:\kafka\jdk-17.0.1现在开始添加环境变量在用户变量path里添加 %JAVA_HOME%\bin和 %JAVA_HO......
- 【项目实战】Java 开发 Kafka 生产者
......
- 【项目实战】Java 开发 Kafka 消费者
......
- mysql 按月自动分区
Mysql按月自动分区实现方法一、整体流程下面是实现mysql按月自动分区的整体流程：步骤描述1创建一个存储过程2获取当前日期3判断是否需要创建新分区4创建新分区5删除过期分区6设置定时任务在以下段落中，我将逐步解释每个步骤需要做什么，并提供相......
- kafka分区分配策略
前言现有主流消息中间件都是生产者-消费者模型，主要角色都是：Producer->Broker->Consumer，上手起来非常简单，但仍有需要知识点需要我们关注，才能避免一些错误的使用情况，或者使用起来更加高效，例如本篇要讲的kafka分区分配策略。在开始前我们先简单回顾一下kafka消息存储设计，如下图......
- mysql写入数据慢
MySQL写入数据慢的原因及优化方法MySQL是一种非常流行的关系型数据库，广泛应用于各种应用程序和网站中。然而，有时我们会遇到MySQL写入数据慢的问题。本文将介绍可能导致写入数据慢的原因，并提供一些优化方法来改善性能。1.原因分析1.1硬件问题首先，我们需要检查硬件是否存在问题......
- python win32com 写入excel
如何使用Python的win32com库写入Excel作为一名经验丰富的开发者，我可以教会你如何使用Python的win32com库来实现在Excel中写入数据的功能。下面是整个流程的步骤表格：步骤描述1导入所需的库2创建Excel应用程序对象3打开或创建Excel工作簿4选择或创建工作表......
- 使用 Apache SeaTunnel 实现 Kafka Source 解析复杂Json 案例
版本说明：SeaTunnel：apache-seatunnel-2.3.2-SNAPHOT引擎说明：Flink：1.16.2Zeta：官方自带前言近些时间，我们正好接手一个数据集成项目，数据上游方是给我们投递到Kafka，我们一开始的技术选型是SpringBoot+Flink对上游数据进行加工处理（下文简称：方案一），由于测试不到位，后来到线上，发现......