下面我们来介绍下Kafka rebalance的原理。kafka的consumer group有多个consumer实例，这些consumer实例是怎么分配topic分区的呢...
发简信
IP属地：辽宁
-
深入理解Kafka(十二) rebalance原理
-
深入理解Kafka(十一) 可用性相关参数
下面我们来介绍下Kafka怎么调优可用性相关的参数。可用性反映的是kafka集群应对崩溃的能力。无论broker,producer,consumer出现崩溃，kafka依然保...
-
深入理解Kafka(十) 延迟时间相关参数
下面我们来介绍下Kafka怎么调优延迟时间相关的参数。对于kafka的不同组件，延迟时间的意义是不同的。对于producer来说，延迟时间主要是发送消息的延时，也就是prod...
-
深入理解Kafka(九) 吞吐量相关参数
下面我们来介绍下Kafka怎么调优吞吐量相关的参数，首先我们需要确定当我们想要调优kafka的时候，我们需要从哪些方面开始呢，一般来说，我们需要从性能，可用性和持久性来做集群...
-
深入理解Kafka(八) 消息可靠性
下面我们来介绍下Kafka怎么保证消息的可靠性，在消息中间件里，有一个非常重要的问题就是怎么保证消息不丢失，而这就是消息的可靠性问题。在介绍Kafka是怎么保证消息不丢失的问...
-
-
配置listener了吗，没有配置当然不执行了
Eureka源码分析（四） EurekaBootStrap
之前我们分析了eureka cilent和eureka server的配置,下面我们来分析一下eureka的启动流程。先来介绍一个类EurekaBootStrap,这个类实现...
-
深入理解Kafka (七) 日志处理
下面我们来说一下Kafka是怎么处理日志的。Kafka中的日志就像数据库中的记录，或者是commit log一样的日志，是按照时间顺序写入的，但是Kafka并不是直接将mes...
-
深入理解Kafka(六) Consumer开发
下面我们来进行consumer的开发。先来写一个Consumer类，在构造方法里初始化KafkaConsumer对象，并设置相应的参数。 Kafka是通过Properties...
-
深入理解Kafka(五) Producer开发
下面我们来实际的使用一下Kafka，看一下是怎么进行消息的生产的。我们先新建一个类Producer，在构造方法中初始化KafkaProducer对象 KafkaProduce...
-
深入理解Kafka(四) 集群管理
下面我们来说一下Kafka的集群管理。我们知道Kafka的高可用是通过集群的方式实现的，那么集群管理是怎么实现的呢？简单来说，Kafka的集群管理就是通过Zookeeper实...
-
深入理解Kafka（三） 请求处理
下面我们来说一下Kafka处理请求的流程。我们知道，Producer发送消息的时候，是用的client发送到socket的，那么broker是怎么处理这些消息的呢，其实很简单...
-
深入理解Kafka（二） Consumer设计
下面来说一下Kafka的consumer设计。在最新版本的Kafka中，consumer group管理依赖于broker的协调者管理consumer的实例并下发分配方案到每...
-
深入理解Kafka(一) Producer设计
下面来说一下一个日志处理平台Kafka，关于Kafka的基本概念先做一个说明：1.producer：消息生产者，发布消息到 kafka 集群的终端或服务。2.broker：k...
-
说一说怎么排查线上问题下面我们来说一下怎么排查线上的问题。我们经常遇到某一个时候，线上的服务突然变慢，或者突然out of memeory了，这个时候你知道怎么排查线上的问题吗，还有突然cpu利用...
-
Java并发编程（十二） CopyOnWriteArrayList
下面我们来说一下CopyOnWriteArrayList。这个类是一个线程安全的集合，通过copy-on-write机制实现的，下面我们就来看一下CopyOnWriteArr...
