wangliucheng created KAFKA-16080:
------------------------------------
Summary: partiton not retention after execute
ALTER_REPLICA_LOG_DIRS and LEADER_AND_ISR request at the same time
Key: KAFKA-16080
URL: https://issues.apache.org/jira/browse/KAFKA-16080
Project: Kafka
Issue Type: Bug
Affects Versions: 3.3.2
Reporter: wangliucheng
Hi,
I found a reproducible problem,
when server running a task which is ALTER_REPLICA_LOG_DIRS
e.g. test-1 /data01/kafka/log/test01-1 -> /data02/kafka/log/test01-1.xxx-future
then
1) thread task kafka-log-retention not work both /data01/kafka/log/test01-1 and
/data02/kafka/log/test01-1.xxx-future,
The result is that the data will not retention while task is running
analysis: The kafka-log-retention thread not work on test01-1 after
invoking logManager.abortAndPauseCleaning(topicPartition)
2) If LEADER_AND_ISR is request while ALTER_REPLICA_LOG_DIRS task is running，
After the task is end, the data which in /data02/kafka/log/test01-1 will
not be deleted all the time
analysis: logManager.abortAndPauseCleaning(topicPartition) invoked twice,
but resumed only once
How to optimize this problem
Thanks
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
