Kafka消费者详解

Kafka消费者详解

Failed to send data to Kafka

kafka 异常

RabbitMQ之延迟队列

​ 延时队列在需要延时处理的场景下非常有用,使用 RabbitMQ 来实现延时队列可以很好的利用 RabbitMQ 的特性,如:消息可靠发送、消息可靠投递、死信队列来保障消息至少被消费一次以及未被正 确处理的消息不会被丢弃。另外,通过 RabbitMQ 集群的特性,可以很好的解决单点故障问题,不会

1、kafka(2.12-3.0.0)介绍、部署及验证、基准测试

Kafka是由Apache软件基金会开发的一个开源流平台,由Scala和Java编写。Publish and subscribe:发布与订阅Store:存储Process:处理Kafka生态圈官网地址:https://cwiki.apache.org/confluence/display/KAFKA

RabbitMQ消息堆积问题及惰性队列

RabbitMQ消息堆积问题及惰性队列

RabbitMQ 管理页面该如何使用

management: 用户可以通过 AMQP 做的任何事 列出自己可以通过 AMQP 登入的 virtual hosts 查看自己的 virtual hosts 中的 queues, exchanges 和 bindings 查看和关闭自己的 channels 和 connections 查看有关

分布式任务调度框架Power-Job

PowerJob可以被认为是第三代任务调度框架,它是新一代分布式任务调度与计算框架,支持CRON、API、固定频率、固定延迟等调度策略,提供工作流来编排任务解决依赖关系,能让您轻松完成作业的调度与繁杂任务的分布式计算,在任务调度的基础上,还额外提供了分布式计算和工作流功能

使用docker搭建minio分布式对象存储系统

使用Docker搭建MinIO分布式对象存储系统可以让您快速搭建和配置一个高性能、可扩展的存储系统。通过简单的步骤,您可以在分布式环境中部署和管理MinIO,并轻松地存储和访问大量的非结构化数据。在本文中,我们将介绍如何使用Docker来搭建MinIO分布式对象存储系统,帮助您快速上手并开始使用分布

【Kafka】消息队列Kafka基础

【Kafka】消息队列Kafka基础

docker启动rabbitmq无法访问15672端口

rabbitmq:3.8版本开始,管理插件包含在RabbitMQ发行版中。与其他任何插件一样,必须先启用它,然后才能使用它。使用rabbitmq:3.8.14版本启动了rabbitmq容器,5672、25672端口都可以连接,唯独15672仅在服务器本地可被连接。执行此命令即可:rabbitmq-p

消息队列——rabbitmq的不同工作模式

4种不同工作模式

springcloud——gateway功能拓展

基于springcloud gateway下,实现获取用户的真实IP、统一跨域配置、redis令牌桶算法限流的功能。

Kafka消费不到数据

方法1:登录bin/zkCli.sh 然后删除kafka中/brokers/topics/__consumer_offsets 节点。看logdir的目录,换个目录或者删除目录中的数据,本机是 rm -rf datas/* (方法2:停止zookeeper: zk.sh stop 查看conf

使用RabbitMQ

【代码】使用RabbitMQ。

windows环境hadoop报错‘D:\Program‘ 不是内部或外部命令,也不是可运行的程序 或批处理文件。

错误:windows环境hadoop报错’D:\Program’ 不是内部或外部命令,也不是可运行的程序 或批处理文件。错误方法:(1)配置HADOOP_HOME环境变量时,将路径中的Program Files修改为Progra~1,以便系统识别,无效(2)将地址中的D:/Program Files

分布式定时任务-XXL-JOB-教程+实战

xxl-job确实很强大,功能也很全,经过该文章学习相信你可以把xxl-job给用起来了,但是如果你的项目是一个小体量的单体,我不太建议使用它,Quzrtz或者SpringBoot Task就足够 ,对于xxl-job个人还是有些笨重。

【MQ】Windows上RabbitMQ的安装与启动

Windows平台下RabbitMQ的安装与启动

一文了解RabbitMQ安装使用

RabbitMQ是一种开源的消息中间件软件,用于构建可扩展的分布式应用程序。它实现了高级消息队列协议(AMQP),这是一种网络协议,用于在应用程序之间进行可靠的异步消息传递。RabbitMQ提供了一个可靠的消息传递系统,使不同的应用程序能够通过消息进行通信。它支持多种消息传递模式,包括点对点、发布/

如何使用RabbitMQ发送和接收消息

本文介绍了如何使用RabbitMQ的Python客户端库pika来发送和接收消息,并提供了示例代码。读者可以根据自己的需求修改代码,例如修改队列名称、发送不同的消息等。RabbitMQ 是一个开源的消息队列软件,可以用于在应用程序之间传递消息。上面的代码分别演示了如何向队列发送消息和从队列接收消息。

使用RabbitMQ死信队列关闭未支付的订单

RabbitMQ死信队列(Dead-Letter Exchange,简称DLX)是一种特殊类型的交换机,用于处理在队列中无法被消费的消息。当消息无法被消费时,它会被转发到死信队列中,以便进一步处理。消息无法被消费者处理:例如,如果消费者崩溃或消息的格式不正确,则无法处理消息。此时,消息将被发送到死信

登录可以使用的更多功能哦! 登录
作者榜
...
资讯小助手

资讯同步

...
内容小助手

文章同步

...
Deephub

公众号:deephub-imba

...
奕凯

公众号:奕凯的技术栈