Kafka高频面试题系列之五（30道）.docx
需积分: 3 75 浏览量
2023-04-04
19:31:14
上传
评论
收藏 142KB DOCX 举报
1、 Kafka 判断一个节点是否还活着有那两个条件？
（1）节点必须可以维护和 ZooKeeper 的连接，Zookeeper 通过心跳机制检查每个节点的连
接
（2）如果节点是个 follower,他必须能及时的同步 leader 的写操作，延时不能太久
2、 Kafka 中的 Offset 是什么？
•Offset 是 kafka 中存储数据时给每个数据做的标记或者编号
•分区级别的编号，每个分区从 0 开始编号
•功能：消费者根据 offset 来进行消费，保证顺序消费以及消费数据的一次性语义
3、 消费者如何不自动提交偏移量，由应用提交？
将 auto.commit.offset 设为 false，然后在处理一批消息后 commitSync() 或者异步提交
commitAsync()
即：
ConsumerRecords<> records = consumer.poll();
for (ConsumerRecord<> record : records){
。。。
tyr{
consumer.commitSync()
}
。。。
}
4、 consumer 是推还是拉？
Kafka 最初考虑的问题是，customer 应该从 brokes 拉取消息还是 brokers 将消息推送到
consumer，也就是 pull 还 push。在这方面，Kafka 遵循了一种大部分消息系统共同的传统
的设计：producer 将消息推送到 broker，consumer 从 broker 拉取消息。
一些消息系统比如 Scribe 和 Apache Flume 采用了 push 模式，将消息推送到下游的
consumer。这样做有好处也有坏处：由 broker 决定消息推送的速率，对于不同消费速率的
consumer 就不太好处理了。消息系统都致力于让 consumer 以最大的速率最快速的消费消
息，但不幸的是，push 模式下，当 broker 推送的速率远大于 consumer 消费的速率时，
consumer 恐怕就要崩溃了。最终 Kafka 还是选取了传统的 pull 模式。
Pull 模式的另外一个好处是 consumer 可以自主决定是否批量的从 broker 拉取数据 。
Push 模式必须在不知道下游 consumer 消费能力和消费策略的情况下决定是立即推送每条
消息还是缓存之后批量推送。如果为了避免 consumer 崩溃而采用较低的推送速率，将可能
导致一次只推送较少的消息而造成浪费。Pull 模式下，consumer 就可以根据自己的消费能
力去决定这些策略。
资源评论
