kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Guozhang Wang <wangg...@gmail.com>
Subject Re: What's the behavior when Kafka is deleting messages and consumers are still reading
Date Tue, 24 Jun 2014 15:17:07 GMT
Hi Li,

The log operations are protected by a lock, so if there is a concurrent
read on this partition it will not be deleted. But then when it is deleted
the next fetch/read will result in a OffsetOutOfRange exception and the
consumer needs to restart from a offset reset value.


On Tue, Jun 24, 2014 at 5:20 AM, Lian, Li <llian@ebay.com> wrote:

> When Kafka broker is trying to delete message according to the log
> retention setting, either triggered by log age or topic partition size, if
> the same time there are still consumers reading the topic, what will happen?
> Best regards,
> Lex Lian
> Email: llian@ebay.com

-- Guozhang

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message