@@ -2688,14 +2688,16 @@ public void checkGC() {
26882688
26892689 replCloseFuture .thenCompose (v -> delete (deleteMode == InactiveTopicDeleteMode .delete_when_no_subscriptions ,
26902690 deleteMode == InactiveTopicDeleteMode .delete_when_subscriptions_caught_up , false ))
2691- .thenApply ((res ) -> tryToDeletePartitionedMetadata ())
2691+ .thenCompose ((res ) -> tryToDeletePartitionedMetadata ())
26922692 .thenRun (() -> log .info ("[{}] Topic deleted successfully due to inactivity" , topic ))
26932693 .exceptionally (e -> {
26942694 if (e .getCause () instanceof TopicBusyException ) {
26952695 // topic became active again
26962696 if (log .isDebugEnabled ()) {
26972697 log .debug ("[{}] Did not delete busy topic: {}" , topic , e .getCause ().getMessage ());
26982698 }
2699+ } else if (e .getCause () instanceof UnsupportedOperationException ) {
2700+ log .info ("[{}] Skip to delete partitioned topic: {}" , topic , e .getCause ().getMessage ());
26992701 } else {
27002702 log .warn ("[{}] Inactive topic deletion failed" , topic , e );
27012703 }
@@ -2740,7 +2742,7 @@ private CompletableFuture<Void> tryToDeletePartitionedMetadata() {
27402742 .filter (topicExist -> topicExist )
27412743 .findAny ();
27422744 if (anyExistPartition .isPresent ()) {
2743- log .error ("[{}] Delete topic metadata failed because"
2745+ log .info ("[{}] Delete topic metadata failed because"
27442746 + " another partition exist." , topicName );
27452747 throw new UnsupportedOperationException (
27462748 String .format ("Another partition exists for [%s]." ,
0 commit comments