手动修复 rabbitmq 报错 “Crash dump is being written to“
(5) 查找 wal 文件路径，查找的路径来自步骤 (4)(3) 在 pod 节点上查看对应的物理设备。此步骤请慎重操作，建议将文件备份后再操作。(7) 删除 pod，重新启动 pod。(6) 删除 wal 文件。(4) 查看设备挂载目录。
Canal-adapter简单介绍及部分源码解析
Canal-adapter简单介绍及部分源码解析
Kafka Connect ：构建强大分布式数据集成方案
在本篇文章中，深入探讨了 Kafka Connect 的核心架构、实战应用以及高级特性。通过详细的示例代码，展示了如何灵活应用 Kafka Connect 进行数据集成，连接多种数据源，实现实时数据流处理，并利用高级特性如Exactly Once语义、数据变换与清洗以及Connector的动态加载，
在flink-connector-jdbc中增加对国产数据库达梦(V8)的支持
本文将展示如何在flink-connector-jdbc中增加对国产数据库达梦(V8)的支持。演示基于Java语言，使用Maven。
Linux(Centos)安装RabbitMQ+延时插件+开机自启动
Linux（Centos）安装RabbitMQ+延时插件+开机自启动
(18)不重启服务动态停止、启动RabbitMQ消费者
我们在消费RabbitMQ消息的过程中，有时候可能会想先暂停消费一段时间，然后过段时间再启动消费者，这个需求怎么实现呢？我们可以借助RabbitListenerEndpointRegistry这个类来实现，它的全类名是org.springframework.amqp.rabbit.listener.
分布式消息队列Kafka（四）- 消费者
可以理解为分配的结果带有“粘性的”。即在执行一次新的分配之前， 考虑上一次分配的结果，尽量少的调整分配的变动，可以节省大量的开销。粘性分区是 Kafka 从 0.11.x 版本开始引入这种分配策略，首先会尽量均衡的放置分区到消费者上面，在出现同一消费者组内消费者出现问题的时候，会尽量保持原有分配的分
基础：Zookeeper、Eureka、Nacos、Consul ，Etcd选型
服务发现就是服务提供者将自己提供的地址post或者update到服务中介，服务消费者从服务中介那里get自己想要的服务的地址。
kafka常见命令介绍和使用
kafka常见命令介绍和使用
项目实战之RabbitMQ重试机制进行消息补偿通知
有关于项目实战之RabbitMQ重试机制进行消息补偿通知到此就结束了。
编译 Flink代码
中，如有问题百度解决，百度没有，多试几次，可能是网络的问题。镜像仓库或者自己搭建的仓库。最重要的是第二个片段的内容。另一种编译命令，相对于上面这个命令，主要的确保是：不编译。当成功编译完成后，上述几种编译方式最终都能在当前。另外，在一些情况下，我们可能并不想把编译后的。查看 Git远程分支，我们选择
kafka分区分配策略
现有主流消息中间件都是生产者-消费者模型，主要角色都是：Producer -> Broker -> Consumer，上手起来非常简单，但仍有需要知识点需要我们关注，才能避免一些错误的使用情况，或者使用起来更加高效，例如本篇要讲的kafka分区分配策略。在开始前我们先简单回顾一下kafka消息存储设
springboot 开启和关闭kafka消费
关闭kafka自动消费，手动开启和关闭kafka消费
springboot集成Flink-CDC
文章目录一、Flink&Flink CDC官网二、CDC&Flink CDC介绍1、 什么是cdc2、什么是Flink CDC3、支持的连接器三、springboot整合Filnk CDC1、官网示例2、Maven依赖1) Flink和Flink CDC版本映射2）具体maven依赖
flink的window和windowAll的区别
window 和windowAll的区别
注册中心ZK、nameServer、eureka、Nacos介绍与对比
微服务架构是存在着很多跨服务调用，每个服务都存在着多个节点，如果有多个提供者和消费者，当提供者增加/减少或者消费者增加/减少，双方都需要感知发现。所以诞生了注册中心这个中间件。市面上有很多注册中心，如 Zookeeper、NameServer、Eureka、Nacos，下面我来讲一下它们的特点、应用
【RabbitMQ】服务启动成功，无法访问localhost:15672（RabbitMQ Management）
RabbitMQ 服务已经启动成功，已经安装rabbitmq_management插件，无法访问RabbitMQ Management（http://localhost:15672/）。
SQL使用技巧(6)HIVE开窗函数
先想明白自己要实现什么样的功能，然后再去实践。没有目的的尝试段不可取，会难以理解各开窗函数的真正用法。
RabbitMQ
下载镜像，镜像中已经安装了管理界面关闭防火墙配置管理员用户名和密码启动Rabbitmq容器访问管理控制台用户名密码是 admin设置rabbitmq服务器。
JAVA发送消息到RabbitMq
大部分业务应用场景中，只需要发送消息到指定的交换机(exchange)中。如果业务需要创建交换机，则将注释的代码打开，创建交换机、队列，并绑定。发送消息时，将对应的交换机、路由进行替换即可。4.1为交换机amq.topic创建一个测试队列并绑定。项目中，作为生产者自定义消息发送到RabbitMq。2
