分布式
-
RabbitMQ(八)消息的序列化
目录 一、为什么需要消息序列化? 二、常用的消息序列化方式 1)Java原生序列化(默认) 2)JSON格式 LocalDateTime、LocalDate 转换问题 解决方式:使…
-
快速了解 Kafka 基础架构
今天来聊下大数据场景下比较流行的消息队列组件 kafka。本篇文章将主要从理论角度来介绍。 kafka 是一款开源、追求高吞吐、实时性,可持久化的流式消息队列,可同时处理在线(消息…
-
kafka 集群 KRaft 模式搭建
Apache Kafka是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序 Kafka 官网:https://kafka.apache….
-
Kafka系列——详解创建Kafka消费者及相关配置
参考自kafka系列文章——消费者创建与配置 创建消费者 在读取消息之前,需要先创建一个 KafkaConsumer 对象。 创建 KafkaConsumer 对象与创建 Kafk…
-
spark.driver.maxResultSize限制 Spark 驱动程序(driver)在向客户端返回结果时的最大大小
org.apache.kyuubi.KyuubiSQLException: org.apache.kyuubi.KyuubiSQLException: Error operatin…
-
【RabbitMQ】交换机详解看这一篇就够了
🎉🎉欢迎来到我的CSDN主页!🎉🎉 🏅我是Java方文山,一个在CSDN分享笔记的博主。Ǵ…
-
【Docker】Docker安装Hadoop分布式集群
Docker安装分布式Hadoop集群 一、准备环境 1. 查看docker的hadoop镜像 docker search hadoop 2. 拉取stars最多的镜像 docke…
-
分布式理论协议与算法 第三弹 BASE理论
大部分人解释这 CAP 定律时,常常简单的表述为:“一致性、可用性、分区容错性三者你只能同时达到其中两个,不可能同时达到”。实际上这是一个非常具有误导性质的说法,而且在 CAP 理…
-
【Kafka-3.x-教程】-【七】Kafka 生产调优、Kafka 压力测试
【Kafka-3.x-教程】专栏: 【Kafka-3.x-教程】-【一】Kafka 概述、Kafka 快速入门 【Kafka-3.x-教程】-【二】Kafka-生产者-Produc…
-
RabbitMQ 的七种消息传递形式
文章目录 一、RabbitMQ 架构简介 二、准备工作 三、消息收发 1. Hello World 2. Work queues 3. Publish/Subscrite 3.1….
-
大数据学习之Hadoop
分布式存储HadoopHDFS 一、分布式与集群 1.分布式:将多台服务器集中在一起,每台服务器都能实现整个中的不同的业务,可以做不同的事。 举例:做一顿年夜饭,一个人…
-
Kafka:主题创建、分区修改查看、生产者、消费者
文章目录 Kafka后台操作 1)主题 2)分区 3)生产者 4)消费者组 Kafka后台操作 1)主题 1.创建主题 ./bin/kafka-topics.sh –create…
-
kafka的 ack 应答机制
目录 一 ack 应答机制 二 ISR 集合 一 ack 应答机制 kafka 为用户提供了三种应答级别: all,leader,0 acks :0 …
-
CentOS7安装部署Zookeeper
文章目录 CentOS7安装部署Zookeeper 一、前言 1.简介 2.架构 3.集群角色 4.特点 5.环境 二、正文 1.部署服务器 2.基础环境 1)主机名 2)Host…
-
Kafka中的Partition详解与示例代码
在Apache Kafka中,Partition(分区)是一个关键的概念。分区的引入使得Kafka能够处理大规模数据,并提供高性能和可伸缩性。本文将深入探讨Kafka中的Parti…
