包含标签：kafka 的文章
-
Kafka源码编译
1. 环境准备 kafka源码编译需要依赖gradle与scale，所以在编译kafka源码之前需要安装配置爱gradle与scala环境。下表是各个环境安装的版本及下载地址，当然还……admin 2021-11-26
-
单节点部署gpmall商城系统
一、案例分析 1.规划节点 IP 主机名 192.168.94.1 mall 2.基础准备 centos7.2系统、yum源使用gpmall-repo包，安装基础环境 二、案例实施 1.修改主…… -
SparkStreaming动态读取kafka生产者生产的数据并将它存入MySQL数据库
SparkStreaming动态读取kafka生产者生产的数据并将它存入MySQL数据库 一、环境准备 二、编写程序 三、进行测试 关于使用sparkstreaming读取kafka生产者…… -
SparkStreaming读取kafka生产的数据，进行累计词频统计后将最新结果存入MySQL数据库
SparkStreaming读取kafka生产的数据，进行累计词频统计后将最新结果存入MySQL数据库 一、环境准备 二、环境启动 三、编写程序 四、进行测试 读取kafka数…… -
kafka安装
我是廖志伟，一名Java开发工程师、幕后大佬社区创始人、Java领域优质创作者、CSDN博客专家。拥有多年一线研发经验，研究过各种常见框架及中间件的底层源码，…… -
图解Kafka中的数据采集和统计机制 | 文末送30本书任你选
?《Kafka运维管控平台》? ✏️更强大的管控能力✏️ ?更高效的问题定位能力? ?更便捷的集群运维能力? ?更专业的资源治理? ?更友好的运维生…… -
Kafka+PowerJob实现延时消息、定时消息，动态控制消息发送时间
前言：因为公司需要一个kafka延时消息的组件服务，看了下市面上的实现kafka延时消息的实现，感觉都比较复杂难理解，自己就去研究了下使用其他中间件进行解决…… -
通过FlinkCDC将MySQL中变更的数据写入到kafka
文章目录 前言 一、CDC的种类？ 二、通过FlinkCDC将数据从MySQL导入到Kafka 1.核心代码 2.工具类 三、结果展示 3.可能会出现的错误及解决 解决： …… -
es报错：request contains unrecognized parameter [ignore_throttled]
问题描述 在使用 Springboot 整合 ES 的时候，使用 Springboot 时，使用的是 Springboot data 提供的工具，具体依赖如下： <dependency> <gr…… -
kafka创建主题时循环报错 java.net.ConnectException: 拒绝连接…【已解决】
今天犯了一个很低级的错误，导致循环报错：拒绝连接。报错信息如下： java.net.ConnectException: 拒绝连接 at sun.nio.ch.SocketChannelImpl.checkC……