如何删除kafka主题数据
kafka消息在过了保留周期之后会被自动清除。但总有一些情况，需要立刻删除消息。假设这样场景：已经开始给kafka主题生产消息的应用发现了缺陷，接着bug修复程序需要更新，这是kafka主题中已经了一些错误的消息。这样场景通常在开发环境，我们需要的就是快速批量删除这些消息。本文介绍了几种方式删除ka
RabbitMQ 之 幂等性
RabbitMQ、幂等性
RabbitMQ(消息丢失、顺序消费)等常见问题与解决方案
首先投递失败存在如下两个情况解决方案：生产者投递消息时指定 mandatory 或者 immediate 参数设为 true ，RabbitMQ 会把无法投递的消息通过 Basic.Return 命令将消息返回给生产者，此时生产者需要调用 channel.addReturnListener 来添加
【大数据存储技术】「#3」将数据从Hive导入到MySQL
【代码】【大数据存储技术】「#3」将数据从Hive导入到MySQL。
ELK采集MySQL慢日志实现
使用ELK采集mysql慢日志进行统计分析
使用jmx exporter采集kafka指标及配置
Jmx exporter中包含了kafka各个组件的指标，如server metrics、producer metrics、consumer metrics等，但这些指标并不是prometheus格式的，因此需要通过重命名方式转变为prometheus格式，重命名规则配置在。并在prometheus
Hadoop集群的搭建（结束）——修改hadoop配置文件以及启动集群服务
（1）修改 hadoop-env.sh 文件（2）修改 yarn-env.sh 文件（3）修改 core-site.xml 文件（4）修改 hdfs-site.xml 文件（5）修改 mapred-site.xml 文件（6）修改 yarn-site.xml 文件（7）修改 masters 文件（8
大数据面试重点之kafka(七)
大数据面试重点之kafka(七)
Superset 安装配置
官网地址Apache Superset 是一个现代的数据探索和可视化平台。它功能强大且十分易用，可对接各种数据源，包括很多现代的大数据分析引擎，拥有丰富的图表展示形式，并且支持自定义仪表盘。Superset快速，轻巧，直观，并带有各种选项，使各种技能的用户都可以轻松浏览和可视化其数据，从简单的折线图
flink定时器（Timer）
定时器 默认的区分精度是毫秒。由于定时器只能在 KeyedStream 上使用，所以到了 KeyedProcessFunction 这里，我们 才真正对时间有了精细的控制，定时方法.onTimer()才真正派上了用场。所以我们会看到，程序运行后先在控制台输出“数据到达”的信息，等待 10 秒之后，
分布式学习-1 Hadoop Spark安装
折腾了一个多月的时间，成功实现了一些应用。学习过程中还是踩了不少坑的，所以在这里对整个构建过程进行整理，方便大家参考学习。
zookeeper集群
zookeeper
如何利用IDEA通过创建Maven项目来实现hadoop相关项目
前言已经安装好IDEA，并且配置好JDK和maven一、创建一个Maven项点击玩Finish之后，等待加载完项目（第一次加载需要等一段时间）如图示，maven项目加载完毕，并将下图所示内容删除二、导入hadoop相关依赖，即修改pom.xml文件在</project>前的<bui
尚硅谷大数据技术Hadoop教程-笔记04【Hadoop-MapReduce】
尚硅谷大数据技术Hadoop教程-笔记04【Hadoop-MapReduce】
解决kafka消费积压问题
压测遇到的消费积压问题
【毕业设计】 大数据地铁客流数据分析系统 - python
🔥 Hi，大家好，这里是丹成学长的毕设系列文章！🔥 对毕设有任何疑问都可以问学长哦!这两年开始，各个学校对毕设的要求越来越高，难度也越来越大… 毕业设计耗费时间，耗费精力，甚至有些题目即使是专业的老师或者硕士生也需要很长时间，所以一旦发现问题，一定要提前准备，避免到后面措手不及，草草了事。为了
大数据框架之Hadoop：MapReduce（三）MapReduce框架原理——OutputFormat数据输出
OutputFormat数据输出
Kafka消费者调优
kafka消费者性能调优
离线数仓-基础知识(个人总结)
声明: 1. 本文为我的个人复习总结, 并非那种从零基础开始普及知识 内容详细全面, 言辞官方的文章  
Flink知识点总结 Flink简介
flink记录
