logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

Kafka 中的消费者位移 __consumer_offsets

Kafka 中的消费者位移 __consumer_offsets__consumer_offsets 在 Kafka 源码中有个更为正式的名字,叫位移主题,即 Offsets Topic。老版本 Consumer 的位移管理是依托于 Apache ZooKeeper 的,它会自动或手动地将位移数据提交到 ZooKeeper 中保存。当 Consumer 重启后,它能自动从 ZooKeeper 中读

主流服务注册中心对比

主流服务注册中心对比ZookeeperZookeeper 是一个分布式服务框架,是 Apache Hadoop 的一个子项目,它主要是用来解决分布式应用中一些经常遇到的一些数据管理问题,如:统一命名服务、状态同步服务、集群管理、分布式应用配置项的管理等。简单来说,zookeeper 本质就是 存储 + 监听通知。zookeeper 用来做服务注册中心,主要是因为它具有节点变更通知功能,只要客户端监

MySQL集群架构 —— 集群架构设计

MySQL集群架构 —— 集群架构设计集群架构设计架构设计理念在集群架构设计时,主要遵从下面三个维度:可用性站点高可用,冗余站点服务高可用,冗余服务数据高可用,冗余数据**保证高可用的方法是冗余。**但是数据冗余带来的问题是数据一致性的问题。实现高可用的方案有以下几种架构模式:主从模式灵活简单,能满足多种需求。比较主流的用法,但是写操作高可用需要自行处理。双主模式互为主从,有双主双写、双主单写两种

Gradle使用阿里云镜像加速

阿里云维护着一个国内 maven 镜像源,同样适用于 gradle。只需在 build.gradle 文件里 添加以下配置即可:repositories {maven {url "http://maven.aliyun.com/nexus/content/groups/public"}}

导入与导出 Docker 镜像与容器

查看 Docker 镜像仓库docker imagessave 导出镜像docker save > logstash.tar docker.elastic.co/logstash/logstash:7.6.1docker save > 文件名.tar 镜像名:tagload 导入镜像docker load < es.tar会自动导入镜像及相关元数据...

#docker
Java 接口是否可以继承多个接口?

Java 接口是否可以继承多个接口?我们都知道,Java类是单继承,那接口可以多继承吗?答案是:Java 接口是可以继承多个接口的Java不允许类多重继承的主要原因是,如果A同时继承B和C,而B和C同时有一个D方法,A如何决定该继承那一个呢?但接口不存在这样的问题,接口全都是抽象方法继承谁都无所谓,所以接口可以继承多个接口。注意:1)一个类如果实现了一个接口,则要实现该接口的所有方法,包括该接口继

MyBatis-Plus 实体类实现动态表名

项目中使用了 MyBatis-Plus 简化开发,在项目中,对数据库表的操作,可以通过在数据表实体类中添加@TableName("table_name") 来指定该实体所对应的表,如下:@TableName("user")@Datapublic class User implements Serializable {private static final long serialVersionUI

【Nginx配置】使用upstream和proxy_pass实现反向代理与负载均衡

Nginx除了实现基本的Web Server功能之外还可以作为正向代理与反向代理。正向代理与反向代理的区别在于代理的对象不一样。正向代理的对象是客户端,反向代理的对象是服务端。做正向代理时,当客户端发起请求其访问目标应该是后端真实服务器;做反向代理时,客户端发起请求其目标应该是代理服务器本身,但由代理服务器把后端真实服务器上的数据发给了客户端。反向代理通常是作为负载均衡...

Kafka CommitFailedException 异常怎么处理?

Kafka CommitFailedException 异常怎么处理?CommitFailedException,顾名思义就是 Consumer 客户端在提交位移时出现了错误或异常,而且还是那种不可恢复的严重异常。如果异常是可恢复的瞬时错误,提交位移的 API 自己就能规避它们了,因为很多提交位移的 API 方法是支持自动错误重试的,比如commitSync()。每次和 CommitFailedE

Kafka 生产者压缩算法

Kafka 生产者压缩算法说起压缩(compression),我相信你一定不会感到陌生。它秉承了用时间去换空间的经典 trade-off 思想,具体来说就是用 CPU 时间去换磁盘空间或网络 I/O 传输量,希望以较小的 CPU 开销带来更少的磁盘占用或更少的网络 I/O 传输。在 Kafka 中,压缩也是用来做这件事的。今天我就来跟你分享一下 Kafka 中压缩的那些事儿。怎么压缩Kafka 是

    共 14 条
  • 1
  • 2
  • 请选择