包含标签:kafka 的文章
-
Kafka源码编译
1. 环境准备 kafka源码编译需要依赖gradle与scale,所以在编译kafka源码之前需要安装配置爱gradle与scala环境。下表是各个环境安装的版本及下载地址,当然还…… -
单节点部署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中的数据采集和统计机制 | 文末送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……