下面我们来介绍下Kafka rebalance的原理。kafka的consumer group有多个consumer实例，这些consumer实...

下面我们来介绍下Kafka怎么调优可用性相关的参数。可用性反映的是kafka集群应对崩溃的能力。无论broker,producer,consum...

下面我们来介绍下Kafka怎么调优延迟时间相关的参数。对于kafka的不同组件，延迟时间的意义是不同的。对于producer来说，延迟时间主要是...

下面我们来介绍下Kafka怎么调优吞吐量相关的参数，首先我们需要确定当我们想要调优kafka的时候，我们需要从哪些方面开始呢，一般来说，我们需要...

下面我们来介绍下Kafka怎么保证消息的可靠性，在消息中间件里，有一个非常重要的问题就是怎么保证消息不丢失，而这就是消息的可靠性问题。在介绍Ka...

下面我们来说一下Kafka是怎么处理日志的。Kafka中的日志就像数据库中的记录，或者是commit log一样的日志，是按照时间顺序写入的，但...

下面我们来进行consumer的开发。先来写一个Consumer类，在构造方法里初始化KafkaConsumer对象，并设置相应的参数。 Kaf...

下面我们来实际的使用一下Kafka，看一下是怎么进行消息的生产的。我们先新建一个类Producer，在构造方法中初始化KafkaProducer...

下面我们来说一下Kafka的集群管理。我们知道Kafka的高可用是通过集群的方式实现的，那么集群管理是怎么实现的呢？简单来说，Kafka的集群管...