kafka常见命令集锦
目标熟悉kafka各个组件的功能。熟练使用zookeeper客户端操作kafka节点，通过命令的方式验证kafka各个组件之间的关联关系。相关概念Brokerkafka节点，多个broker组成kafka集群。Topic即主题，kafka通过Topic对消息进行分类，发布到kafka的消息都需要指定
详解Spark运行模式（local+standalone+yarn）
Spark 有多种运行模式：1.可以运行在一台机器上，称为 Local（本地）运行模式。2.可以使用 Spark 自带的资源调度系统，称为 Standalone 模式。3.可以使用 Yarn、Mesos、Kubernetes 作为底层资源调度系统，称为 Spark On Yarn、Spark On
kafka日志清理
kafka日志清理
RabbitMQ 死信队列详解
一、死信的概念死信，顾名思义就是无法被消费的消息。一般来说，Producer 将消息投递到 Broker 或者直接到 Queue 里了，Consumer 从 Queue 取出消息进行消费，但某些时候由于特定的原因导致 Queue 中的某些消息无法被消费，这样的消息如果没有后续的处理，就变成了死信，有
RabbitMQ-客户端源码之AMQConnection
如果是其他帧，则判断其frame.channel值是否为0，frame.channel值为0代表的是特殊帧，这些特殊帧是和Connection有关的，而不是和Channel有关的（上面代码里的frame.channel就是Channel里的channel number, 一般Connection类型
java理论知识之Kafka
Kafka 起初是由 Linkedin 公司采用 Scala 语言开发的一个多分区、多副本且基于ZooKeeper协调的分布式消息系统。 目前 Kafka 已经定位为一个分布式流式处理平台，它以高吞吐、可持久化、可水平扩展、支持流数据处理等多种特性而被广泛使用。
RabbitMQ五大模式轻松理解
简要概括RabbitMQ工作模式：1、简单模式 HelloWorld 2、工作队列模式 Work Queue 3、发布订阅模式 Publish/subscribe 4、路由模式 Routing 5、通配符模式 Topic
超级无敌详细使用ubuntu搭建hadoop完全分布式集群
先关闭master虚拟机然后点击虚拟机-----管理----克隆----下一步----下一步----选择创建完全克隆----下一步----更改虚拟机名称为slave1，位置自己选择即可。注意此时slave1和slave2虚拟机是克隆的，所以说配置文件和master是完全相同的，登录的话也是maste
SpringBoot中使用Redis实现分布式锁
SpringBoot中使用Redis实现分布式锁
在Linux下Jmeter的分布式配置
一、Jdk的安装：1、 上传 jdk-8u221-linux-x64.tar.gz 到 Linux 的/usr/local 目录下2、 解压：tar xvf jdk-8u221-linux-x64.tar.gz3、 修改配置文件：vi /etc/profile4、 光标移动到最后一行，添加以下配置e
【kafka-ui】支持kafka with kraft的可视化集群管理工具
支持kafka3.3.1的kafka可视化客户端，并且可以连接带认证的kafka集群
Kafka生产者——消息发送流程，同步、异步发送API
Kafka的Producer发送消息采用的是异步发送的方式。在消息发送的过程中，涉及到了两个线程:main线程和Sender线程，以及一个线程共享变量:RecordAccumulator。①main线程中创建了一个双端队列RecordAccumulator，将消息发送给RecordAccumulat
Kafka同步发送与异步发送消息
生产者同步发消息，在收到kafka的ack告知发送成功之前一直处于阻塞状态
PHP分布式部署代码同步Git实现
php 分布式代码自动同步
CentOS7 Hadoop 3.3.4 集群安装（1 NameNode，3 DataNode）
CentOS7下安装Hadoop3.3.4集群，一个NameNode节点，三个DataNode节点
通过Java操作Kafka
通过Java操作Kafka
rabbitMQ 消息顺序性、消息幂等性、消息不丢失、最终一致性、补偿机制、消息队列设计
消息顺序性、消息幂等性、消息不丢失、最终一致性、补偿机制、消息队列设计
Kafka 学习笔记
为什么使用消息队列？以用户下单购买商品的行为举例，在使用微服务架构时，我们需要调用多个服务。传统的调用方式是同步调用，这会存在一定的性能问题使用消息队列可以实现异步的通信方式，相比于同步的通信⽅式，异步的⽅式可以让上游快速成功，极大提高系统的吞吐量。在分布式系统中，通过下游多个服务的分布式事务的保障
kafka的分区详解
kafka的分区副本机制分区Leader选举☆分区重新分配☆创建集群和主题查看主题详情再添加一个分区再添加一个节点重新分配修改副本因子分区策略RangeAssignor分配策略RoundRobinAssignor分配策略StickyAssignor自定义分配策略主要内容 : kafka分区的管理
kafka保证数据有序性小结
最近，项目中使用过kafka但是不太理解，然后各种搜博客补习。然后对kafka如何保证数据的有序性很感兴趣，于是乎，又疯狂找博客学习，现在可以说是小有心得，在这里记录一下，怕忘记。也作为给大家的一个分享。本文内容为集多家之长，根据自己的理解就诞生了这篇内容，开始。自己在学习的过程中，看完博客结合自己
