[GitHub] [kafka] lindong28 commented on pull request #5694: KAFKA-7441; Allow LogCleanerManager.resumeCleaning() to be used concurrently

[GitHub]

Would code look a bit more elegant by doing this:

```
            case Some(state) =>
              state match {
                case LogCleaningPaused(count) if count == 1 => 
                  inProgress.remove(topicPartition)
                case LogCleaningPaused(count) if count > 1 =>
                  inProgress.put(topicPartition, LogCleaningPaused(count - 1))
                case s =>
                  throw new IllegalStateException(s"Compaction for partition 
$topicPartition cannot be resumed since it is in $s state.")
              }
```

[ Full content available at: https://github.com/apache/kafka/pull/5694 ]
This message was relayed via gitbox.apache.org for devnull@infra.apache.org