spring 中kafka的基本使用
springboot中使用kafka，批量消费，到业务处理
ZooKeeper实战总结
注意：本文参考菜鸟教程。
elasticsearch的.security-7索引崩溃恢复笔记
elasticsearch的.security-7索引崩溃恢复笔记
JDBC连接Impala——ImpalaJDBC41
JDBC连接Impala——ImpalaJDBC41，依赖报错，找不到数据库
SpringBoot整合实现RabbitMQ
RabbitMQ是由erlang语言开发，基于AMQP（Advanced Message Queue 高级消息队列协议）协议实现的消息队列，它是一种应用程序之间的通信方法，消息队列在分布式系统开发中应用非常广泛。创建2个springboot项目，一个 mq-rabbitmq-producer（生产者
【MQ系列】查看RabbitMQ的版本号
如果上述报错，则试试下面的方法。
spring boot与spring cloud版本兼容问题解决（附版本兼容表）
spring cloud和spring boot版本兼容问题
Zookeeper下载和安装
Zookeeper下载安装教程：本地安装，集群安装
hive 入门 配置hiveserver2 (三)
Hive的hiveserver2服务的作用是提供jdbc/odbc接口，为用户，例如用户期望在个人电脑中访问远程服务中的Hive数据，就需要用到Hiveserver2。
flink-cdc,clickhouse写入，多路输出
高级：入clickhouse的同时推送到kafka供2次数据流程处理。kafka日志数据从kafka读取。2、判断日志内容级别：多路输出。1、关联字典表：完善日志数据。低级：入clickhouse。
消息队列详解
文章目录1、什么是 MQ1、什么是 MQMQ 全称 Message Queue，也就是我们所说的消息队列。消息队列就是在消息的传输过程中保存消息的容器，多用于分布式系统之间进行通信。RabbitMQ是流行的消息队列服务软件，是开源的AMQP（高级消息队列协议）实现。支持多种客户端，如：Java、Py
mysql报错：1044 -Access denied for user ‘root‘@‘%‘ to database
在服务器的docker容器内，MySQL5.7版本中新建数据库报错:报错是因为root没有权限的原因，找到一下两种解决办法：查询用户表看root用户权限修改权限，命令如下：2.赋权mysql赋权操作，总结命令如下：两个方法都可以试试，我遇到这个问题时把两个方法用了一遍，中间忘记重启容器了，所以不知道
RabbitMQ启动失败
首先，你得先确认的你得Erlang的版本和RabbitMQ的版本是否能相互兼容，如果不能，请先下载对应的Erlang版本或者RabbitMQ版本。1.在Java中使用了RabbitMQ发现不停的尝试连接，却连不上的问题先在cmd下输入erl，看一下Erlang的环境变量配没有没有上图这个结果的，先配
Flink web UI 打开不了解决办法
flink web开启不了
EIK+Filebeat+Kafka
KAFKA详解、kafka部署、EIK+Filebeat+Kafka部署
使用Elasticsearch进行分组聚合统计
使用Elasticsearch进行分组聚合统计
flink 对每天的数据进行汇总
但是，这样的话，窗口将不会每来一条数据触发一次计算，而是要等到该窗口的 Watermark 推进到窗口结束时间后才会触发计算。MySQLSink为将数据写入到mysql，进行了更新和新增操作，根据生成的key，对数据先进行修改动作，若修改失败，则进行新增，保证一天内，聚合的数据的唯一性。使用flin
RabbitMQ常见问题以及实际问题解决
当生产者发送消息的速度超过了消费者处理消息的速度，就会导致队列中的消息堆积，直到队列存储消息达到上限。最早接收到的消息，可能就会成为死信，会被丢弃，这就是消息堆积问题。RabbitMQ支持消费者确认机制，即：消费者处理消息后可以向MQ发送ack回执，MQ收到ack回执后才会删除该信息。我们可以利用S
Rabbitmq消息积压问题如何解决？
Rabbitmq消息积压问题如何解决？
flink启动后web访问问题
在执行./start-cluster.sh 后，flink进程的监听ip端口是。这样只能本机进行访问，外部服务器是访问不了的，出现这个问题的原因是flink的。所以启动后就解析到127.0.0.1了。, 进程启动时会按照这个主机名从。
