![](../../asset/images/user/bgImg_default.jpeg)
简介
该用户还未填写简介
擅长的技术栈
可提供的服务
暂无可提供的服务
对未完成的事务而言,LSO 的值等于事务中第一条消息的位置(firstUnstableOffset),对已完成的事务而言,它的值同 HW 相同;为了解决 HW 更新时机是异步延迟的,而 HW 又是决定日志是否备份成功的标志,从而造成数据丢失和数据不一致的现象,Kafka 引入了 leader epoch 机制;LW:(low watermark)一个副本的log中,最小的消息偏移量;这个值规定了消
![文章图片](https://img-blog.csdnimg.cn/img_convert/f47eba77896a4514ac359eab015666ca.png)
消息系统都致力于让consumer以最大的速率最快速的消费消息,但不幸的是,push模式下,当broker推送的速率远大于consumer消费的速率时,consumer恐怕就要崩溃了。消费者组的意义:(可以让多个消费者组成一个组,并共同协作来消费数据,提高消费并行度)一个消费组中的各消费者,在消费一个topic的数据时,互相不重复!也就是说,如果你给 log.dirs 参数新增了一个新的磁盘,新的
![文章图片](https://img-blog.csdnimg.cn/img_convert/f47eba77896a4514ac359eab015666ca.png)
Controller作为Kafka集群中的核心组件,它的主要作用是在 Apache ZooKeeper 的帮助下管理和协调整个 Kafka 集群。Controller与Zookeeper进行交互,获取与更新集群中的元数据信息。其他broker并不直接与zookeeper进行通信,而是与 Controller 进行通信并同步Controller中的元数据信息。Kafka集群中每个节点都可以充当Con
![文章图片](https://img-blog.csdnimg.cn/img_convert/f47eba77896a4514ac359eab015666ca.png)
如果将 retries参数配置为非零值,并且 max .in.flight.requests.per.connection 参数配置为大于1的值,那可能会出现错序的现象:如果批次1消息写入失败,而批次2消息写入成功,那么生产者会重试发送批次1的消息,此时如果批次1的消息写入成功,那么这两个批次的消息就出现了错序。一般而言,在需要保证消息顺序的场合建议把参数max.in.flight.request
![文章图片](https://img-blog.csdnimg.cn/img_convert/f47eba77896a4514ac359eab015666ca.png)
Git本地有三个工作区域:工作目录(Working Directory)、暂存区(Stage/Index)、资源库(Repository或Git Directory)。如果在加上远程的git仓库(Remote Directory)就可以分为四个工作区域。文件在这四个区域之间的转换关系。这里可以选择notepad++也可以使用默认的vim。创建全新的仓库,需要用GIT管理的项目的根目录执行。设置本机
![文章图片](https://img-blog.csdnimg.cn/img_convert/418a5cc2b4434b7cacbe969d0605b3a4.png)