public Future<Void> migrateFromDeploymentToStrimziPodSets(Deployment deployment, StrimziPodSet podSet)    {
        if (deployment == null) {
            // Deployment does not exist anymore => no migration needed
            return Future.succeededFuture();
        } else {
            int depReplicas = deployment.getSpec().getReplicas();
            int podSetReplicas = podSet != null ? podSet.getSpec().getPods().size() : 0;

            return moveOnePodFromDeploymentToStrimziPodSet(depReplicas - 1, Math.min(podSetReplicas + 1, connect.getReplicas()));
        }
    }
@Test
    public void testNoMigrationToPodSets(VertxTestContext context)  {
        KafkaConnectMigration migration = new KafkaConnectMigration(
                RECONCILIATION,
                CLUSTER,
                null,
                null,
                1_000L,
                false,
                null,
                null,
                null,
                null,
                null,
                null
        );

        Checkpoint async = context.checkpoint();
        migration.migrateFromDeploymentToStrimziPodSets(null, CLUSTER.generatePodSet(3, null, null, false, null, null, null))
                .onComplete(context.succeeding(v -> context.verify(async::flag)));
    }