KIP-853: KRaft Controller Membership Changes ,其中较为重要的一点特性为,通过外围脚本对 controller 的成员进行动态增删。
prophet 安装及相关问题
没想到坑那么多 …
大模型应用开发阶段性总结:入门、rag 和 eino
最近几个月与大模型应用开发相关的一些总结
kafka 匿名 consumergroup 消费堆积监控适配
需要有些关于 __consumer_offsets 作用的小知识
三十岁以前的往事(十三):持续进化
continue envolving …
kafka client 并发处理单 partition 异常场景分析
为什么不推荐并发处理单 partition 的数据
使用 map-reduce 按行比较两组数据的 diff
对于大批量的数据,使用本地的 diff 命令比较速度慢,推荐采用 map-reduce 的方式来进行。本文的主要内容为 mr 相关脚本的实现及分析。
使用 awk 命令按行的第一列取两个文件的交集
注意,仅能处理第一列没有重复数据的情况。
sarama 获取 kafka topic & consumergroup 基础信息代码样例
主要的信息为:
全量 topic 列表
单个 topic 的基础信息
全量 consumergroup
单个 consumergroup 的基础信息