【中间件】RabbitMQ 自定义重试次数（针对同一模块不同消费者）
最近遇到了关于 RabbitMQ 的问题，打比方说：某个微服务模块中，RabbitMQ 的大部分消费者需要重试两次，而小部分消费者由于特殊原因并不需要进行重试。这就涉及到自定义重试次数的话题了，但在网上找了一圈没发现相关的，但是功夫不负有心人，最后还是解决了这个问题，接下来给大家分享一下~
zookeeper集群启停及状态查看脚本（linux）
zookeeper基本脚本
Kafka消费者详解
Kafka消费者详解
Doris 入门：高级特性（四）
目录一、表结构变更二、Rollup三、增大内存四、修改超时时间五、Broadcast/Shuffle Join六、数据模型七、索引八、物化视图九、动态分区十、数据导出十一、Colocation Join十二、SQL 函数一、表结构变更添加列：alter table table1 add column
Hive（23）：Select高级查询之SORT/ORDER/CLUSTER/DISTRIBUTE BY
order by会对输入做全局排序，因此只有一个reducer，会导致当输入规模较大时，需要较长的计算时间。sort by不是全局排序，其在数据进入reducer前完成排序。因此，如果用sort by进行排序，并且设置mapred.reduce.tasks>1，则sort by只保证每个reduce
Failed to send data to Kafka
kafka 异常
elasticsearch 之 updateByQuery
elasticsearch 之 updateByQuery ，通过script脚本完成对文档字段的更新
SpringBoot——》@KafkaListener
SpringBoot——》@KafkaListener
logstash连接elasticsearch被拒绝，如何解决-
账号密码都配置正确了，但是还是连接不上。
大数据Flink（五十二）：Flink中的批和流以及性能比较
Spark和Flink全部都运行在Hadoop YARN上，性能为Flink > Spark > Hadoop(MR)，迭代次数越多越明显，性能上，Flink优于Spark和Hadoop最主要的原因是Flink支持增量迭代，具有对迭代自动优化的功能。也即是有明确的开始和结束的定义。注入的顺序不是必须
Java使用poi-tl生成word模板-动态数据列表
Java使用poi-tl生成word模板-动态数据列表
RabbitMQ之延迟队列
延时队列在需要延时处理的场景下非常有用，使用 RabbitMQ 来实现延时队列可以很好的利用 RabbitMQ 的特性，如：消息可靠发送、消息可靠投递、死信队列来保障消息至少被消费一次以及未被正 确处理的消息不会被丢弃。另外，通过 RabbitMQ 集群的特性，可以很好的解决单点故障问题，不会
Prometheus之rabbitmq监控指标详解
rabbitmq_messages_deliver_no_ack_rate指标可以帮助您了解未确认消息的数量和速率，并确定是否需要更改客户端消费者的配置或调整队列和交换机的配置以改善系统性能。与"rabbitmq_queue_messages_ready"指标不同的是，它不是单个队列的指标，而是Ra
[Docker]使用Docker部署Kafka
Kafka 是一个分布式流处理平台，它依赖于 ZooKeeper 作为其协调服务。在 Kafka 集群中，ZooKeeper 负责管理和协调 Kafka 的各个节点。因此，要在 Docker 容器中启动 Kafka，通常需要同时启动一个 ZooKeeper 服务作为其依赖。可以按照以下步骤来启动 K
1、kafka（2.12-3.0.0）介绍、部署及验证、基准测试
Kafka是由Apache软件基金会开发的一个开源流平台，由Scala和Java编写。Publish and subscribe：发布与订阅Store：存储Process：处理Kafka生态圈官网地址：https://cwiki.apache.org/confluence/display/KAFKA
【大数据】通过 docker-compose 快速部署 MinIO 保姆级教程
MinIO 是一个开源的对象存储服务器，它兼容Amazon S3（Simple Storage Service）API。它被设计用于构建分布式存储架构，提供高可用性、高性能和可扩展的对象存储解决方案。
将list对象存储进redis中去
Redis存储支持的类型没有object，虽然有支持list，但是它只支持list。所以我们可以将list对象转换成json字符串,然后再将字符串传入到redis中去。
Flink 状态后端
状态后端 (state backend) : 负责管理本地状态的存储方式, 位置。
HIVE创建分区表
partitioned by ( c2 string ) # 创建分区 c1跟c2都是字段，但是创建的时候不能写在t2里面，只能写在分区里面（同时select查询的时候，c2的字段也要写在最后面）注意：当你退出过hive后，再次进入hive，不要忘记使用了哪个database，我这里使用的是te
Hadoop: High Available
即HDFS 支持一主一备的架构最多支持 5 个，官方推荐使用 3 个基于Hadoop3.x. 总的来说就是要借助Zookeeper来实现高可用,然后就是编辑Hadoop的配置文件已实现高可用[email protected]。
