Yeah, and I thought I answered your question? I think the compaction happens 
when new segments are created.

Sorry if I’m still misunderstanding.

> On Jan 19, 2018, at 3:55 PM, Rahul Bhattacharjee <rahul.rec....@gmail.com> 
> wrote:
> 
> Thanks Matt for the response .I was asking about the log compaction
> <https://kafka.apache.org/documentation/#compaction> of kafka topics.
> 
> On Fri, Jan 19, 2018 at 12:36 PM, Matt Farmer <m...@frmr.me> wrote:
> 
>> Someone will need to correct me if I’m wrong, but my understanding is that
>> a topic log on disk is divided into segments. Compaction will occur when a
>> segment “rolls off” - so when a new active segment is created and the
>> previous segment becomes inactive.
>> 
>> Segments can be bounded by size and time in topic and broker configuration
>> to get the effect that you want.
>> 
>>> On Jan 19, 2018, at 2:10 PM, Rahul Bhattacharjee <
>> rahul.rec....@gmail.com> wrote:
>>> 
>>> Let's say we have a compacted topic (log.cleanup.policy=compact) where
>> lot
>>> of updates happen for relatively small set of keys.
>>> My question is when does the compaction happen.
>>> 
>>> In memtable , when a new update comes for an already existing key in
>>> memtable , the value is simple replaced.
>>> or,
>>> all the updates are associated with a offset , later the memtable is
>>> spilled to disk and the deletion happens during compaction phase.
>>> 
>>> thanks,
>>> Rahul
>> 
>> 

Reply via email to