“坏邻居”导致的kafka生产者TPS下降原因排查
java压测注意事项 kafka压测过程中的坏邻居
Kafka搭建部署
Kafka搭建部署
RabbitMQ实现延时消息的两种方法
因此我们只需要在声明正常的业务队列时添加一个可选的"x-dead-letter-exchange"参数，值为死信交换机，死信就会被rabbitmq重新publish到配置的这个交换机上，我们接着监听这个交换机就可以了。如果当一个队列各个消息的过期时间不一致时，使用死信队列就可能达不到延时的作用。当我
Kafka消费者无法消费数据，解决
解决Kafka消费者无法消费数据问题
【复盘】记录一次类型不一致导致的Kafka消费异常问题
记录一次生产事故
Pyspark 基础知识
Pyspark基础知识，包括Pyspark基本介绍，和Spark框架对比，WordCount执行流程，Pyspark执行原理等
使用批处理文件(.bat)启动多个CMD窗口并执行命令
由于每次启动本机的kafka都需要打开2个cmd窗口，分别启动zookeeper服务和kafka服务，操作相对繁琐，于是想起了批处理来帮忙一键启动。4. 使用choice命令来延时3秒，也可用ping命令作延时，ping 127.0.0.1 -n 5。2. cmd /k 表示cmd后面的命令执行完后
关于kafka连接超时的解决思路
kafka启动出现超时的一种解决思路
kafka消费失败重试机制
kafka批量消费时，消息消费失败处理
RabbitMq应用延时消息
RabbitMq延时消费
kafka基础
kafka是一个消息队列的中间件，那什么是消息队列？生产者：负责生产消息，将消息发送给broker，是全部消息的发起者。broker：是消息的服务端，负责消息的存储、投递等功能，是最核心的部分。消费者：负责消息的消费，根据消息承载的信息处理对应逻辑。它的应用场景有：消息的异步处理：比如用户注册发送验
查看RabbitMQ日志---trace插件的使用
同时，RabbitMQ的Web管理界面也提供了相应的命令行界面（Command UI），您可以在 "Admin"（或 "Management"）选项卡中找到 "Command UI" 子选项卡来执行相应的命令。在您登录的RabbitMQ管理界面中，导航到 "Admin"（或 "Management"
Kafka 为什么那么快？
批量发送：减少了与服务端。
Windows操纵kafka
【代码】Windows操纵kafka。
ZooKeeper的集群部署和启动与关闭
分别在虚拟机Spark01、Spark02和Spark03 的/export/data/zookeeper/zkdata目录中创建myid文件，在虚拟机Spark01的myid文件中写入值1，在虚拟机Spark02的myid文件中写入值2，在虚拟机Spark03的myid文件中写入值3。”命令编辑Z
【项目实战】Kafka 重平衡 Consumer Group Rebalance 机制
Kafka重平衡是指Apache Kafka分布式消息系统中的一个过程。在Kafka中，消息被分区并分布在不同的主题中的多个分区中。每个消费者组可以订阅一个或多个主题，并从分区中消费消息。当消费者加入或离开消费者组时，或者主题的分区数量发生变化时，Kafka会触发重平衡过程。重平衡的目的是重新分配分
【项目实战】Kafka 的 Leader 选举和负载均衡
Kafka的Leader选举和负载均衡是保证高可用性、故障恢复、负载均衡和性能优化的重要机制。它们能够确保Kafka集群的稳定运行和高效处理大量数据的能力
Linux-centos7安装rabbitmq
安装并启动 RabbitMQ 后，可以使用 RabbitMQ 的命令行工具 rabbitmqctl 来管理 RabbitMQ。1、安装Erlang，RabbitMQ是使用Erlang语言编写的，所以需要先安装Erlang。需要再重启一波rabbit server。才能进入127.0.0.1:1567
（五）「消息队列」之 RabbitMQ 主题（使用 .NET 客户端）
基于模式（主题）接收消息
pylink消费kafka写入ES
"enable.auto.commit": "false", # 关闭kafka 自动提交，此处不能传bool 类型会报错。(\d{26}).*?).name(f"消费{TEST_KAFKA_TOPIC}主题数据")# 创建 StreamExecutionEnvironment 对象。# id表示
