kafka

一.版本兼容的问题 因为某个功能需要对接的kafka是一个上古版本0.10.0.0，公司项目又是springcloud项目，导致版本兼容性的问题很头大 1.kafka的版本号 下载…

Kafka新特性 概述 新增 改进： 重点功能 分层存储 集群配置 优点 支持 不支持 主页传送门：📀 传送 概述 上个月kafka刚刚更新了新版本3.6.0，下面…

“我翻开招聘APP一查，这上面没有功能测试，歪歪斜斜的每页上都写着“大数据”几个字。我横竖睡不着，仔细看了半夜，才从字缝里看出字来，满本都写着两个字是“kafka”！” 那么让我们…

GitHub源码https://github.com/zhangchuangiie/SimpleKafka SimpleKafka（Kafka客户端封装工具类） 一个基于Kafka…

Flink实现同时消费多个kafka topic，并输出到多个topic 1.说明 2.依赖引用 3. 方案一：适用于==sink topic==存在跨集群等kafka生产者配置信…

目录 一.定时计算与实时计算 二. 实时流式计算 1.概念 2. 应用场景 3.技术方案选型 三. Kafka Stream 1 概述 2.Kafka Streams的关键概念 3…

Kafka 监听器详解 Kafka Assistant 是一款 Kafka GUI 管理工具——管理Broker,Topic,Group、查看消费详情、监控服务器状态、支持多种消息…

首先我们来花两分钟了解一下： 什么是zookeeper？ 什么是kafka？ 为什么kafka依赖zookeeper和javaSDK？ Zookeeper 和 Kafka 都是 A…

文章目录 一、jdk安装 二、安装zookeeper 1、下载并解压zookeeper 2、修改zoo.cfg配置文件 3、添加zookeeper环境变量 4、启动zookeepe…

目录 1、概念介绍 Kafka 由来 ZooKeeper Kafka 特性 Kafka 使用场景 Kafka 复制备份  2、Kafka 架构 Broker Topic Produ…

概述： 本文主要分享Kafka客户端的元数据如何创建，及其内部结构和对象 一、介绍MetaData 客户端元数据在初始化生产者客户端时被创建，以缓存的形式保存在客户端本地内存中； …

1.查看消费者列表 –list bin/kafka-consumer-groups.sh –bootstrap-server hadoop102:9092,hadoo…