[ 
https://issues.apache.org/jira/browse/KAFKA-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Jason Gustafson resolved KAFKA-6429.
------------------------------------
    Resolution: Fixed

> dirtyNonActiveSegments in `cleanableOffsets` should only be created when 
> log.cleaner.min.compaction.lag.ms > 0
> --------------------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-6429
>                 URL: https://issues.apache.org/jira/browse/KAFKA-6429
>             Project: Kafka
>          Issue Type: Bug
>          Components: log
>    Affects Versions: 1.0.0
>            Reporter: huxihx
>            Assignee: huxihx
>            Priority: Minor
>
> LogCleanerManager.cleanableOffsets always created objects to hold all dirty 
> non-active segments, as shown below:
> {code:java}
> // dirty log segments
>     val dirtyNonActiveSegments = log.logSegments(firstDirtyOffset, 
> log.activeSegment.baseOffset)
> {code}
> Actually, these objects will not be used when 
> `log.cleaner.min.compaction.lag.ms` is 0 which is already the default value. 
> We could defer the creation. In doing so can we reduce the heap size but also 
> avoid the blocking access to the segments incurred by Log.segments.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to