Fix Kafka CRD API version
@@ -47,7 +47,7 @@ public class KafkaMetaDataRetrieval extends ComponentMetadataRetrieval {
private static final Logger LOG = LoggerFactory.getLogger(KafkaMetaDataRetrieval.class);
static final CustomResourceDefinition KAFKA_CRD = new CustomResourceDefinitionBuilder()
- .withApiVersion("apiextensions.k8s.io/v1beta2")
+ .withApiVersion("apiextensions.k8s.io/v1")
.withKind("CustomResourceDefinition")
.withNewMetadata()
.withName("kafkas.kafka.strimzi.io")
