[
https://issues.apache.org/jira/browse/KAFKA-9265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vikas Singh reassigned KAFKA-9265:
----------------------------------
Assignee: Vikas Singh
> kafka.log.Log instances are leaking on log delete
> -------------------------------------------------
>
> Key: KAFKA-9265
> URL: https://issues.apache.org/jira/browse/KAFKA-9265
> Project: Kafka
> Issue Type: Bug
> Reporter: Vikas Singh
> Assignee: Vikas Singh
> Priority: Major
>
> KAFKA-8448 fixes problem with similar leak. The {{Log}} objects are being
> held in {{ScheduledExecutor}} {{PeriodicProducerExpirationCheck}} callback.
> The fix in KAFKA-8448 was to change the policy of {{ScheduledExecutor}} to
> remove the scheduled task when it gets canceled (by calling
> {{setRemoveOnCancelPolicy(true)}}).
> This works when a log is closed using {{close()}} method. But when a log is
> deleted either when the topic gets deleted or when the rebalancing operation
> moves the replica away from broker, the {{delete()}} operation is invoked.
> {{Log.delete()}} doesn't close the pending scheduled task and that leaks Log
> instance.
> Fix is to close the scheduled task in the {{Log.delete()}} method too.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
