rabbitmq kafka
Kafka-基础
## 1. 简介 **Kafka（Apache Kafka）** 是一种分布式流数据平台，最初由LinkedIn开发，并于后来捐赠给Apache软件基金会，成为了一个Apache顶级项目。它被设计用于处理大规模、实时的数据流，并为构建高吞吐量、容错性强的数据流应用程序提供支持。Kafka的特点使得它 ......
CentOS 安装 RabbitMQ
## 安装： > https://www.rabbitmq.com/download.html ### 1、环境 查看系统版本 ```bash # lsb_release -a # cat /etc/centos-release ``` 操作系统：CentOS 7.9 64位； > 注意：如果操作系 ......
【Kafka3.0】消费者Consumer
[toc] ## kafak消费者 ### 消费者总体工作流程 - **kafka消费方式：**consumer采用从broker中主动拉取的方式去消费数据（pull）。为什么不是broker主动推送呢（push），是因为由broker决定发送速率很难适应所有消费者。pull模式的缺点是kafka没 ......
【kafka3.0】生产者producer
[toc] ## kafka生产者 ### 生产者消息发送流程 #### 发送原理 在消息发送的过程中，涉及到了两个线程——main 线程和 Sender 线程。在 main 线程中创建了一个双端队列 RecordAccumulator。main 线程将消息发送给 RecordAccumulat ......
docker安装RabbitMQ
一、在线安装 1.查询rabbitmq的镜像 docker search rabbitmq 2.安装镜像如果需要安装其他版本在rabbitmq后面跟上版本号即可 docker pull rabbitmq:3.7.7-management docker pull rabbitmq:版本号 -manag ......
【Kafka3.0】broker、producer、consumer详解
# kafka3.0 [toc] ## 1. 什么是kafka？ - Kafka传 统定义：Kafka是一个分布式的基于发布/订阅模式的消息队列（MessageQueue），主要应用于大数据实时处理领域。 - Kafka最 新定义 ： Kafka是 一个开源的 分布式事件流平台 （Event Str ......
RabbitMQ Stream类型队列
RabbitMQ提供了三种类型的队列： Classic Quorum Stream 官方文档 对于流队列的描述是：高性能、可持久化、可复制、非破坏性消费、只追加写入的日志 使用场景： 一个队列将同一条消息分发给不同消费者 可重复消费消息 更高的性能 存储大量消息而不影响性能 更高的吞吐 基本使用 生 ......
Windows下安装Rabbitmq
# Windows下安装Rabbitmq RabbitMQ是实现了高级消息队列协议（AMQP）的开源消息代理软件（亦称面向消息的中间件）。RabbitMQ服务器是用Erlang语言编写的。安装rabbitmq需要先安装erlang环境。 # 环境 - Windows11 我们首先需要下载两个安装包 ......
rabbitmq
[toc] # 一 消息队列介绍 ## 1.1 介绍 消息队列就是基础数据结构中的“先进先出”的一种数据机构。想一下，生活中买东西，需要排队，先排的人先买消费，就是典型的“先进先出” message queue：消息队列 简称mq ## 1.2 消息队列解决什么问题？ MQ是一直存在，不过随着微服务 ......
kafka安装以及参数
kafka 安装 安装JDK yum install -y java-1.8.0-openjdk.x86_64 查看版本 java -version kafka是分布式的，需要多台机器，并且保证机器之间是免密登录同时需要用zookeeper集群负责管理。 1、kafka版本选择，从官网下载即可，我这 ......
Kafka在企业级应用中的实践
前言 前面说了很多Kafka的性能优点，有些童鞋要说了，这Kafka在企业开发或者企业级应用中要怎么用呢？今天咱们就来简单探究一下。 1、 使用 Kafka 进行消息的异步处理 Kafka 提供了一个可靠的消息传递机制，使得企业能够将不同组件之间的通信解耦，实现高效的异步处理。在企业级应用中，可以通 ......
kafka经验
使用kafka经验 前言 本篇文章主要介绍的关于本人从刚工作到现在使用kafka的经验，内容非常多，包含了kafka的常用命令，在生产环境中遇到的一些场景处理，kafka的一些web工具推荐等等。由于kafka这块的记录以及经验是从我刚开始使用kafka，从2017年开始，可能里面有些内容过时，请见 ......
Flink-读Kafka写Hive表
1. 目标 使用Flink读取Kafka数据并实时写入Hive表。 2. 环境配置 EMR环境：Hadoop 3.3.3, Hive 3.1.3, Flink 1.16.0 根据官网描述： https://nightlies.apache.org/flink/flink-docs-release-1 ......
SpringAMQP整合RabbitMQ使用
初步理解及下载安装 转自：https://blog.csdn.net/qq_32431981/article/details/124267963 SpringAmqp的官方地址：https://spring.io/projects/spring-amqp SpringAMQP提供了三个功能： 自动声 ......
Kafka - 线上集群部署方案怎么做？
既然是集群，那必然就要有多个 Kafka 节点机器，因为只有单台机器构成的 Kafka 伪集群只能用于日常测试之用，根本无法满足实际的线上生产需求。而真正的线上环境需要仔细地考量各种因素，结合自身的业务需求而制定。下面我就分别从操作系统、磁盘、磁盘容量和带宽等方面来讨论一下。 操作系统 -- 选择L ......
Kafka - 各个历史版本的重大改进
Kafka版本号解释 前面的版本号2.11是编译 Kafka 源代码的 Scala 编译器版本。 Kafka 服务器端的代码完全由 Scala 语言编写 Kafka 新版客户端代码完全由 Java 语言编写 Kafka各个历史版本的重大改进 Kafka 目前总共演进了 7 个大版本，分别是 0.7、 ......
Kafka - 应该选择哪种Kakfa? Apache/Confluent/CDH/HDP
三种kafka的优缺点 Apache Kafka，也称社区版 Kafka。优势在于迭代速度快，社区响应度高，使用它可以让你有更高的把控度；缺陷在于仅提供基础核心组件，缺失一些高级的特性。 社区版 Kafka 只提供一种连接器，即读写磁盘文件的连接器，而没有与其他外部系统交互的连接器，在实际使用过程中 ......
Kafka - 不仅是消息引擎，还是分布式流处理平台
如果你通读全篇文字但只能记住一句话，我希望你记住的就是这句 Apache Kafka 是消息引擎系统，也是一个分布式流处理平台（Distributed Streaming Platform） 作为流处理平台，Kafka 与其他主流大数据流式计算框架相比，优势在哪里呢？我能想到的有两点。 第一点是更容 ......
Kafka - 为什么 Kafka 不像 MySQL 那样允许追随者副本对外提供读服务？
几个原因： 1，kafka的分区已经让读是从多个broker读从而负载均衡，不是MySQL的主从，压力都在主上； 2，kafka保存的数据和数据库的性质有实质的区别就是数据具有消费的概念，是流数据，kafka是消息队列，所以消费需要位移，而数据库是实体数据不存在这个概念，如果从kafka的follo ......
kafka的下载和了解
可以登录Apache kafka 官方下载 https://kafka.apache.org/downloads.html 下载Scala 2.13 - kafka_2.13-3.3.1.tgz (asc, sha512) 官方推荐下载scala 2.13版本的。 kafka作为一个分布式流平台，有 ......
RabbitMQ 管理页面该如何查看有哪些连接
用浏览器访问 http://192.168.1.100:15672 默认 用户名：admin 密码： admin 登陆后显示 在 Connections 页中 查看所有连接 ......
SpringBoot整合kafka配置多个kafka配置
依赖 <dependency> <groupId>org.springframework.kafka</groupId> <artifactId>spring-kafka</artifactId> <version>2.6.0</version> </dependency> yml配置 有几个就配置 ......
kafka笔记
1、 kafka broker是kafka的节点信息，相当于服务器节点信息。 2、 kafka的作用是在业务高峰时起到削峰的作用、同时解除生产者和消费者的耦合作用让生产者不再强关联。 3、 kafka可以分为生产者和消费者单topic模式，生产者生产数据后消费者就会删除数据 kafka可以分为多to ......
10在centos7安装RabbitMQ Server
一.erlang环境安装 erlang语言环境和RabbitMQ版本的对应关系如下: https://www.rabbitmq.com/which-erlang.html 本次安装RabbitMQ 3.11.20 和 erlang 25.3.2.5 进入erlang官网下载 https://www. ......
Kafka为什么这么快？
Kafka 是一个基于发布-订阅模式的消息系统，它可以在多个生产者和消费者之间传递大量的数据。Kafka 的一个显著特点是它的高吞吐率，即每秒可以处理百万级别的消息。那么 Kafka 是如何实现这样高得性能呢？本文将从七个方面来分析 Kafka 的速度优势。 - 零拷贝技术 - 仅可追加日志结构 - ......
centos7下安装rabbitmq3.8
curl -s https://packagecloud.io/install/repositories/rabbitmq/erlang/script.rpm.sh | sudo bash curl -s https://packagecloud.io/install/repositories/ra ......
20,000+ 字，彻底搞懂 Kafka！
## **1、为什么有消息系统** ##### 1、解耦合 ##### 2、异步处理 例如电商平台，秒杀活动。 一般流程会分为： 1. 风险控制 2. 库存锁定 3. 生成订单 4. 短信通知 5. 更新数据 通过消息系统将秒杀活动业务拆分开，将不急需处理的业务放在后面慢慢处理； 流程改为： 1. ......
Kafka生产问题总结及性能优化实践
Kafka可视化管理工具kafka-manager 安装及基本使用可参考：https://www.cnblogs.com/dadonggg/p/8205302.html 线上环境规划 JVM参数设置 kafka是scala语言开发，运行在JVM上，需要对JVM参数合理设置，参看JVM调优专题 修改b ......