public Future<KafkaVersionChange> reconcile()    {
        return getPods()
                .compose(this::detectToAndFromVersions)
                .compose(i -> prepareVersionChange());
    }
@Test
    public void testExistingClusterWithNewMetadataVersion(VertxTestContext context) {
        VersionChangeCreator vcc = mockVersionChangeCreator(
                mockKafka(VERSIONS.defaultVersion().version(), "3.4-IV2", "3.6"),
                mockRos(mockUniformPods(VERSIONS.defaultVersion().version()))
        );

        Checkpoint async = context.checkpoint();
        vcc.reconcile().onComplete(context.succeeding(c -> context.verify(() -> {
            assertThat(c.from(), is(VERSIONS.defaultVersion()));
            assertThat(c.to(), is(VERSIONS.defaultVersion()));
            assertThat(c.metadataVersion(), is("3.6"));

            async.flag();
        })));
    }