@Override
    public ConnectClusterDetails clusterDetails() {
        return clusterDetails;
    }
@Test
    public void kafkaClusterId() {
        assertEquals(KAFKA_CLUSTER_ID, connectClusterState.clusterDetails().kafkaClusterId());
    }