Java面试题

题目

讲讲 kafka 维护消息状态跟踪的方法。

答案

Kafka 是通过 customer 端对消息的 pull。控制权放在 customer 端。kafka 这边将 pardition 放在多个 broker 上面。customer 消费的时候只消费指定的分区。一个分区只能够被一个 customer 消费。数据存放的时候有 offset 的概念。消费者消费的时候会记录自己消费到的 offset。如果想要重新消费，只需要改变自己对应的 offset 值即可。