1：订阅主题和分区 KafkaConsumer.subscribe有下面四种方法， 可以一次性订阅多个主题，并且自定义在均衡监听器方法(Cons...

1概念： 消费者负责订阅主题，并且从主题上拉取消息，与其他消息中间件的不同是，kafka的消费理念中还有一个消费者组的概念，每个消费者都对应一个...

1生产者发送消息到broker 需要经过拦截器，序列化器，分区器。那么经过这些之后，是怎么到达broker的？ 主线程，消息累加器（Record...

（）1序列化(key.serializer 和 value.serializer 参数设置，和自定义序列化器) kafka 自带String、D...

1 、消息发送方法：Producer.send(new ProducerRecord()) 2 、Producer 生产者对象，这个对象是线程安...

producer 生产者 发送消息 consumer 消费者 消费消息（主动拉取） broker （消息服务） kafka 集群： 由多个bro...

原理 主从复制中有两个 thread 分别为 sql thread 和I/O Thread 主服务器 执行的sql 语句都需要 在二进制文件 b...