面试题Kafka问题之Kafka的消费者（Consumer）跟踪消息如何解决-阿里云开发者社区

面试题Kafka问题之Kafka的消费者（Consumer）跟踪消息如何解决

2024-07-24 43

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 面试题Kafka问题之Kafka的消费者（Consumer）跟踪消息如何解决

Kafka的生产者（Producer）如何决定消息的分区？

参考回答：

Kafka的生产者在默认情况下会把消息均衡地分布到主题的所有分区上。决定分区的方式有直接指定、根据消息的key散列取模得出分区，以及轮询指定分区。

关于本问题的更多问答可点击原文查看：

Kafka的消费者（Consumer）是如何跟踪消息的？

参考回答：

Kafka的消费者通过偏移量来区分已经读过的消息。每个消费者会保存它所消费的分区的偏移量，以便在关闭或重启后能够继续从上次的位置开始消费。

关于本问题的更多问答可点击原文查看：

Kafka的消费组（ConsumerGroup）有什么作用？

参考回答：

Kafka的消费组保证每个分区只能被一个消费者使用，从而避免重复消费。如果消费组内的某个消费者失效，消费组里的其他消费者可以接管失效消费者的工作，实现消费的再平衡。

关于本问题的更多问答可点击原文查看：

Kafka中的节点（Broker）和集群是如何工作的？

参考回答：

Kafka中的节点（Broker）连接生产者和消费者，负责接收来自生产者的消息，为消费者提供服务。Kafka集群由多个Broker组成，每个分区都有一个首领Broker负责分区复制和协调。

关于本问题的更多问答可点击原文查看：

Kafka的生产者Offset和消费者Offset有什么区别？

参考回答：

Kafka的生产者Offset指的是消息写入时每个分区的最新最大偏移量。而消费者Offset则是不同消费组中的消费者针对每个分区存储的已消费消息的偏移量，用于跟踪消费者的消费进度。

关于本问题的更多问答可点击原文查看：

面试题Kafka问题之Kafka的消费者（Consumer）跟踪消息如何解决