rabbitmq kafka
RabbitMQ安装与使用
# 系统环境 1、JDK1.8 2、Centos7-64位 3、Erlang-OTP 23 4、RabbitMQ-3.8.5 **linux版本信息查看** `cat /proc/version` Linux version 3.10.0-1127.el7.x86_64 (mockbuild@kbu ......
docker-compose多服务器部署kafka集群
- Kafka 是一个开源的分布式事件流平台，依赖Zookeeper或者KRaft，本文基于Zookeeper。 ## 服务器IP配置 本文使用三个服务器来做集群搭建，IP如下： | nodeName | IP | | | | | node1 | 10.10.210.96 | | node2 | 1 ......
部署rabbitmq
文章目录 一、Erlang 1. Erlang下载 2. Erlang 上传并解压 3. 验证rabbitmq依赖是否安装 4. 安装rabbitmq依赖 5. Erlang 编译、安装 6. Erlang 配置环境变量 7. Erlang 验证 二、RabbitMQ 2.1. RabbitMQ 下 ......
kafka学习之三_信创CPU下单节点kafka性能测试验证
# kafka学习之三_信创CPU下单节点kafka性能测试验证 ## 背景 ``` 前面学习了 3controller+5broker 的集群部署模式. 晚上想着能够验证一下国产机器的性能. 但是国产机器上面的设备有限. 所以想着进行单节点的安装与测试. 并且记录一下简单结果 希望对以后的工作有指 ......
死信队列 - 死信交换机绑定配置【RabbitMQ】
一、逻辑图 二、死信交换机绑定配置 1 package cn.itcast.mq.config; 2 3 import org.springframework.amqp.core.*; 4 import org.springframework.context.annotation.Bean; 5 i ......
kafka的学习之一_带SASL鉴权的集群安装与启动
# kafka的学习之一_带SASL鉴权的集群安装与启动 ## 背景 ``` 想开始一段新的里程. 可能会比现在累, 可能会需要更多的学习和努力. kafka可能就是其中之一. 自己之前总是畏缩不前. 不想面对很多压力. 年龄已经很大了, 必须得向前看继续努力了. ``` ## 关于kafka `` ......
kafka的学习之二_kafka的压测与GUI管理
# kafka的学习之二_kafka的压测与GUI管理 ## 第一部分创建topic ``` cd /root/kafka_2.13-3.5.0 bin/kafka-topics.sh --create --bootstrap-server 10.110.139.184:9093 --command ......
windows环境下安装RabbitMQ（超详细）
windows环境下安装RabbitMQ（超详细） https://blog.csdn.net/qq_25919879/article/details/113055350 luckySnow-julyo 已于 2023-03-21 16:26:29 修改 66281 收藏 755分类专栏： rabb ......
Spring整合RabbitMQ详细解读
Spring整合RabbitMQ的步骤 代码示例骨架 POM.xml文件中的依赖包 生产者模块代码实现 消费者模块代码实现 运行结果 Spring整合RabbitMQ的步骤 使用Spring进行整合，可以使代码变得更加简单，逻辑更加清晰 代码示例骨架 在一个工程中创建了两个模块，一个是生产者一个是消 ......
RabbitMQ高级之消息可靠性投递
什么是可靠性投递？ 生产者：作为消息发送方希望杜绝任何消息丢失或者投递失败场景。 RabbitMQ 为我们提供了两种方式用来控制消息的投递可靠性模式。 分别是： confirm 确认模式 return 退回模式 消息投递路线 如下所示是生产者到消费者的模型： RabbitMQ的整个消息投递的路径 P ......
使用 JMX-Exporter 监控 Kafka 和 Zookeeper
JVM 默认会通过 JMX 的方式暴露基础指标，很多中间件也会通过 JMX 的方式暴露业务指标，比如 Kafka、Zookeeper、ActiveMQ、Cassandra、Spark、Tomcat、Flink 等等。掌握了 JMX 监控方式，就掌握了一批程序的监控方式。本节介绍 JMX-Export ......
Kafka的文件顺序读写
# 背景说明 Kafka使用起来很方便，而且磁盘写入性能非常好，那么它是如何实现的呢。 在[Kafka的文档](https://kafka.apache.org/documentation/#persistence)说明中，有这样一段：  的方式提供消息持久化能力，即使对 TB 级以上数据也能保证常数时间复杂度的访问性能。 高吞吐率。即使在非常廉价的商 ......
kafka的启动--windows版
首先下载并安装kafka 然后进入到安装目录输入cmd 然后先启动zookeerper输入下面的命令 zookeeper-server-start.bat ../../config/zookeeper.properties 再启动kafka，输入下面命令 kafka-server-start.bat ......
SpringBoot整合RabbitMQ -- 直连交换机模式
前提是电脑上已经安装 RabbitMQ 第一步： 第二步： 第三步： 第四步： ......
kafka的一些工作总结
1.如果kafka一个topic下有多个partition（比如18个），如何将数据平均分配到每个partition？ （1）如果能够一次性能够获取总数量，可以用数据的总数量/partition数量(18)， 取平均后分配数据； （2）如果数据是逐一获取的，不能事先获取总数量，可以用获取的数据取ha ......
docker 安装kafka
docker run -d --name zookeeper --publish 2181:2181 --volume /etc/localtime:/etc/localtime zookeeper:latest docker run -d --name kafka --publish 9092:9 ......
RabbitMQ快速使用代码手册
本篇博客的内容为RabbitMQ在开发过程中的快速上手使用，侧重于代码部分，几乎没有相关概念的介绍，相关概念请参考以下csdn博客，两篇都是我找的精华帖，供大家学习。本篇博客也持续更新~~~ ......
kafka重平衡
rebalance 的触发条件有三种： 组成员发生变更（新 consumer 加入组、已有 consumer 主动离开组或已有 consumer 崩溃了——这两者的区别后面会谈到）订阅主题数发生变更订阅主题的分区数发生变更 ......
Kafka系列---【kafka常用命令】
# kafka常用命令 ## 1.查看消费者组列表 ```shell ./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list ``` ## 2.查看指定groupid的消费状态详情 ```shell #能查看partit ......
SpringBoot快速整合RabbitMq小案例
对于一个直接创建的springBoot项目工程来说，可以按照以下步骤使用rabbitmq - 添加依赖：添加rabbitMQ的依赖。 ~~~java org.springframework.boot spring-boot-starter-amqp ~~~ - 配置连接：在配置文件中配置虚拟主机、端 ......
SpringBoot集成kafka
环境springboot2.7 +kafka3.0。kafka安装请自行百度，话不多说直接上代码。 1、添加maven依赖 <dependency> <groupId>org.springframework.kafka</groupId> <artifactId>spring-kafka</arti ......