【Kafka】《Kafka权威指南》——提交和偏移量

KafkaConsumer(消费者)每次调用 poll()方法，它老是返回由生产者写入 Kafka但尚未被消费者读取过的记录， 咱们因 此能够追踪到哪些记录是被群组里的哪一个消费者读取的。以前已经讨论过， Kafka 不会像其余 JMS 队列那样须要获得消费者的确认，这是 Kafka 的一个独特之处。相反，消 费者可使用 Kafka来追踪消息在分区里的位置(偏移量)。 咱们把更新分区当前位置的操做

>>阅读原文<<