回答了问题2019-09-27
问题找到了,是容器的原因。背景信息没补充完全,应用是跑在docker里的,jstack看了下,新生代的gc线程有54条,但是容器给的配置只有6核,所以可以确认JVM拿错了CPU的核心数,拿到的是物理机的核心数。增加了参数-XX:ParallelGCThreads=6 -XX:ConcGCThreads=6,现在...
关注了问题2019-09-24
提出了问题2019-09-24
提出了问题2019-09-24
发布了文章2018-06-05
kafka每个topic有多个partition,单个partition内消息有序。Partition在物理存储上由多个segment组成,每个segment内包含两个文件,index文件和log文件。物理实体 index文件和log文件逻辑实体 topic > partition > segment
发布了文章2018-06-05
Kafka在0.8以前的版本,并不提供高可用机制,一旦一个broker宕机,则宕机期间该broke上的所有partition均不可用。从0.8版本开始,kafka开始提供高可用机制。Kafka的高可用是通过多副本机制保证的。每个topic下的partition都有主分区以及多个follower(该值可在创建to...
发布了文章2018-06-04
broker:存储消息的物理实体,无状态,可多个扩展部署Topic:一类消息的集合Partition:一类消息的某个消息分区,一个topic有多个partition,可部署在多个broker上Replicas:备份,partition级别,单个partition可有多个replicas,保证高可用Controller:主broker,...
发布了文章2018-06-03
broker:存储消息的物理实体,无状态,可多个扩展部署Topic:一类消息的集合Partition:一类消息的某个消息分区,一个topic有多个partition,可部署在多个broker上Replicas:备份,partition级别,单个partition可有多个replicas,保证高可用Controller:主broker,...