[ https://issues.apache.org/jira/browse/KAFKA-16114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825153#comment-17825153 ]
wangliucheng commented on KAFKA-16114: -------------------------------------- Hello, are you interested in seeing this issue? I think it's a serious bug. [~dengziming] [~divijvaidya] [@clolov|https://github.com/clolov] > Fix partiton not retention after cancel alter intra broker log dir task > ------------------------------------------------------------------------ > > Key: KAFKA-16114 > URL: https://issues.apache.org/jira/browse/KAFKA-16114 > Project: Kafka > Issue Type: Bug > Components: log > Affects Versions: 3.3.2, 3.6.1 > Reporter: wangliucheng > Priority: Major > > The deletion thread will not work on partition after cancel alter intra > broker log dir task > The steps to reproduce are as follows: > 1、Create reassignment.json file > test01-1 on the /data01/kafka/log01 directory of the broker 1003,then move to > /data01/kafka/log02 > {code:java} > { > "version": 1, > "partitions": [ > { > "topic": "test01", > "partition": 1, > "replicas": [1001,1003], > "log_dirs": ["any","/data01/kafka/log02"] > } > ] > }{code} > 2、Kick off the reassignment > {code:java} > bin/kafka-reassign-partitions.sh -bootstrap-server localhost:9092 > --reassignment-json-file reassignment.json -execute {code} > 3、Cancel the reassignment > {code:java} > bin/kafka-reassign-partitions.sh -bootstrap-server localhost:9092 > --reassignment-json-file reassignment.json -cancel {code} > 4、Result, The partition test01-1 on 1003 will not be deleted > The reason for this problem is the partition has been filtered: > {code:java} > val deletableLogs = logs.filter { > case (_, log) => !log.config.compact // pick non-compacted logs > }.filterNot { > case (topicPartition, _) => inProgress.contains(topicPartition) // skip any > logs already in-progress > } {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)