private void removeReplicationThrottleForPartitions(TopicPartition part) {
        try (Admin admin = Admin.create(Collections.singletonMap(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, clusterInstance.bootstrapServers()))) {
            removePartitionReplicaThrottles(admin, new HashSet<>(singleton(part)));
            assertDoesNotThrow(() -> throttleAllBrokersReplication(admin, asList(0, 1, 2, 3), Integer.MAX_VALUE));
        }
    }
Remove a set of throttled partitions and reset the overall replication quota.
tools/src/test/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommandTest.java