logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

kafka 生产者压缩算法

kafka消息分区机制 为什么要压缩如何压缩何时压缩何时解压缩各种压缩算法对比为什么要压缩  压缩是一种时间换空间的动作。具体来说就是用CPU时间去换取磁盘空间或网络I/O传输量,希望以较小的CPU开销带来更少的磁盘占用或者更少的网络I/O传输。如何压缩  要搞清楚kafka如何压缩消息。就要从kafka的消息格式说起。目前kafka的有两大类消息格式:V1版本和V2版本。  无论是那个版本,ka

#kafka
kafka的Java生产者如何管理TCP连接

kafka的Java生产者如何管理TCP连接 为何要使用TCP开发一个生产者程序的步骤什么时候创建TCP连接?创建连接地方什么时候会更新元数据呢?有两种情况:何时关闭连接为何要使用TCP  Apache Kafka的所有通信都是基于TCP的,而不是基于HTTP或者其它协议。无论是生产者,消费者,还是Broker之间的通信都是基于TCP。此时就会问:为什么不用HTTP呢?  不用HTTP原因如下:1

#kafka
kafka位移提交详解

kafka位移提交 什么是位移提交,定义。位移提交的分类自动提交和手动提交:同步提交和异步提交什么是位移提交,定义。  Consumer需要向kafka汇报自己的位移数据,这个汇报过程称为位移提交。因为Consumer可以同时消费多个分区。所以位移提交是按照分区的粒度进行的。即Consumer需要为分配给他的每个分区提交各自的位移数据。  作用是:位移提交表示了Consumer的消费进度。这样当C

#kafka
kafka java消费者是如何管理TCP连接的

kafka java消费者是如何管理TCP连接的何时创建连接创建几个连接何时关闭连接何时创建连接  根据我以前的文章,我们知道kafka的java生产者在实例已经创建,就创建了TCP连接。生产者的入口类KafkaProducer在构建实例时,会在后台启动Sender线程,这个线程负责Sockert连接的创建。  那java的消费者是什么时候创建的连接呢?是实例创建时吗?并不是,消费者是在调用Kaf

#kafka
Java实现图片上传功能(前后端:vue+springBoot)

Java实现图片上传功能(前后端:vue+springBoot) 前言:前端:组件引入基础文件上传自定义上传方法后端:需要引入的jar包:基础文件上传Controller层:server层:自定义的多参数接口前言:  我们在设计自己的网站的时候,一定会遇到上传图片的功能,比如:用户头像,商品图片。  这篇文章将带着大家设计一个可以使用的图片上传功能,请大家一步一步来,让我们在码路上越走越远。前端:

#vue.js#java#spring boot
git rebase (合并代码和整理提交记录)图文详解

使用rebase 可以进行 合并代码以及整理提交记录。本文使用完整的图文讲解,对rebase进行了详细的说明,使用命令进行执行,执行之后的图片、结果都进行了说明。对操作过程中可能出现的问题也进行了说明解释。

文章图片
#git
git reset 命令详解 git revert命令详解。

git reset 是代码回退到某一版本,git revert 是代码将某一次提交的代码改动回退掉(新建一个commit记录进行回退)。在git的这些命令中git reset是最长常用的,也是最危险的最容易被误用的。它的主要参数是:soft,mixed,hard它们告诉git,当执行reset是,要对index和working copy做什么。

文章图片
#git#github#npm
git status时有Untracked files(racked files(未跟踪)的文件,原因分析以及解决方案,git clean详解

git status时有Untracked files(racked files(未跟踪)的文件,git clean详解原因分析问题解决第一种情况:第二种情况:第三种情况:原因分析  我们要真正弄明白问题的原因,我们就要先知道文件的几个状态。git在未commit之前有三种状态:Untracked files 未跟踪Changes not staged for commit未提交的更改Change

#git#github#macos
git checkout 命令图文详解

git checkout 命令图文详解git checkout branchname (切换本地分支)切换远程分支放弃修改git checkout .git checkout -- filenamegit checkout -f检出文件,分支转换。git checkout branchname (切换本地分支)切换到”branchname“分支,注意是本地分支。切换远程分支需要先将远程分支与本地分

#git#github
Kafka消费者组

Kafka消费者组 什么是kafka消费者组消费者组的特性为什么出现消费者组针对Consumer Group,Kafka如何管理位移(offset)?kafka的Rebalance(重平衡)定义触发条件问题什么是kafka消费者组  kafka消费者组(Consumer Group)是kafka提供的可扩展且具有容错性的消费者机制。  它是一个组,所以内部有可以有多个消费者,这些消费者共用一个ID

#kafka
    共 16 条
  • 1
  • 2
  • 请选择