Class KafkaResource
- java.lang.Object
-
- io.strimzi.systemtest.resources.crd.KafkaResource
-
public class KafkaResource extends Object
-
-
Constructor Summary
Constructors Constructor Description KafkaResource()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static io.strimzi.api.kafka.model.KafkacreateAndWaitForReadiness(io.strimzi.api.kafka.model.Kafka kafka)static voiddeleteKafkaWithoutWait(String resourceName)This method is used for delete specific Kafka cluster without wait for all resources deletion.static StringgetKafkaExternalListenerCaCertName(String namespace, String clusterName, String listenerName)static io.strimzi.api.kafka.model.status.KafkaStatusgetKafkaStatus(String clusterName, String namespace)static StringgetKafkaTlsListenerCaCertName(String namespace, String clusterName, String listenerName)static io.strimzi.api.kafka.model.KafkaBuilderkafkaAndCruiseControlWithMetrics(String name, int kafkaReplicas, int zookeeperReplicas)static io.fabric8.kubernetes.client.dsl.MixedOperation<io.strimzi.api.kafka.model.Kafka,io.strimzi.api.kafka.KafkaList,io.fabric8.kubernetes.client.dsl.Resource<io.strimzi.api.kafka.model.Kafka>>kafkaClient()static io.strimzi.api.kafka.model.KafkaBuilderkafkaEphemeral(String clusterName, int kafkaReplicas)static io.strimzi.api.kafka.model.KafkaBuilderkafkaEphemeral(String clusterName, int kafkaReplicas, int zookeeperReplicas)static io.strimzi.api.kafka.model.KafkaBuilderkafkaFromYaml(File yamlFile, String clusterName, int kafkaReplicas, int zookeeperReplicas)static io.strimzi.api.kafka.model.KafkaBuilderkafkaJBOD(String name, int kafkaReplicas, int zookeeperReplicas, io.strimzi.api.kafka.model.storage.JbodStorage jbodStorage)static io.strimzi.api.kafka.model.KafkaBuilderkafkaJBOD(String name, int kafkaReplicas, io.strimzi.api.kafka.model.storage.JbodStorage jbodStorage)static io.strimzi.api.kafka.model.KafkaBuilderkafkaPersistent(String name, int kafkaReplicas)static io.strimzi.api.kafka.model.KafkaBuilderkafkaPersistent(String clusterName, int kafkaReplicas, int zookeeperReplicas)static io.strimzi.api.kafka.model.KafkaBuilderkafkaWithCruiseControl(String name, int kafkaReplicas, int zookeeperReplicas)static io.strimzi.api.kafka.model.KafkakafkaWithCruiseControlWithoutWait(String name, int kafkaReplicas, int zookeeperReplicas)static io.strimzi.api.kafka.model.KafkaBuilderkafkaWithMetrics(String name, int kafkaReplicas, int zookeeperReplicas)static io.strimzi.api.kafka.model.KafkaBuilderkafkaWithMetricsAndCruiseControlWithMetrics(String name, int kafkaReplicas, int zookeeperReplicas)static io.strimzi.api.kafka.model.KafkakafkaWithoutWait(io.strimzi.api.kafka.model.Kafka kafka)This method is used for deploy specific Kafka cluster without wait for all resources.static voidreplaceKafkaResource(String resourceName, Consumer<io.strimzi.api.kafka.model.Kafka> editor)
-
-
-
Method Detail
-
kafkaClient
public static io.fabric8.kubernetes.client.dsl.MixedOperation<io.strimzi.api.kafka.model.Kafka,io.strimzi.api.kafka.KafkaList,io.fabric8.kubernetes.client.dsl.Resource<io.strimzi.api.kafka.model.Kafka>> kafkaClient()
-
kafkaEphemeral
public static io.strimzi.api.kafka.model.KafkaBuilder kafkaEphemeral(String clusterName, int kafkaReplicas)
-
kafkaEphemeral
public static io.strimzi.api.kafka.model.KafkaBuilder kafkaEphemeral(String clusterName, int kafkaReplicas, int zookeeperReplicas)
-
kafkaPersistent
public static io.strimzi.api.kafka.model.KafkaBuilder kafkaPersistent(String name, int kafkaReplicas)
-
kafkaPersistent
public static io.strimzi.api.kafka.model.KafkaBuilder kafkaPersistent(String clusterName, int kafkaReplicas, int zookeeperReplicas)
-
kafkaJBOD
public static io.strimzi.api.kafka.model.KafkaBuilder kafkaJBOD(String name, int kafkaReplicas, io.strimzi.api.kafka.model.storage.JbodStorage jbodStorage)
-
kafkaJBOD
public static io.strimzi.api.kafka.model.KafkaBuilder kafkaJBOD(String name, int kafkaReplicas, int zookeeperReplicas, io.strimzi.api.kafka.model.storage.JbodStorage jbodStorage)
-
kafkaWithMetrics
public static io.strimzi.api.kafka.model.KafkaBuilder kafkaWithMetrics(String name, int kafkaReplicas, int zookeeperReplicas)
-
kafkaWithCruiseControl
public static io.strimzi.api.kafka.model.KafkaBuilder kafkaWithCruiseControl(String name, int kafkaReplicas, int zookeeperReplicas)
-
kafkaAndCruiseControlWithMetrics
public static io.strimzi.api.kafka.model.KafkaBuilder kafkaAndCruiseControlWithMetrics(String name, int kafkaReplicas, int zookeeperReplicas)
-
kafkaWithMetricsAndCruiseControlWithMetrics
public static io.strimzi.api.kafka.model.KafkaBuilder kafkaWithMetricsAndCruiseControlWithMetrics(String name, int kafkaReplicas, int zookeeperReplicas)
-
kafkaFromYaml
public static io.strimzi.api.kafka.model.KafkaBuilder kafkaFromYaml(File yamlFile, String clusterName, int kafkaReplicas, int zookeeperReplicas)
-
createAndWaitForReadiness
public static io.strimzi.api.kafka.model.Kafka createAndWaitForReadiness(io.strimzi.api.kafka.model.Kafka kafka)
-
kafkaWithoutWait
public static io.strimzi.api.kafka.model.Kafka kafkaWithoutWait(io.strimzi.api.kafka.model.Kafka kafka)
This method is used for deploy specific Kafka cluster without wait for all resources. It can be use for example for deploy Kafka cluster with unsupported Kafka version.- Parameters:
kafka- kafka cluster specification- Returns:
- kafka cluster specification
-
kafkaWithCruiseControlWithoutWait
public static io.strimzi.api.kafka.model.Kafka kafkaWithCruiseControlWithoutWait(String name, int kafkaReplicas, int zookeeperReplicas)
-
deleteKafkaWithoutWait
public static void deleteKafkaWithoutWait(String resourceName)
This method is used for delete specific Kafka cluster without wait for all resources deletion. It can be use for example for delete Kafka cluster CR with unsupported Kafka version.- Parameters:
resourceName- kafka cluster name
-
replaceKafkaResource
public static void replaceKafkaResource(String resourceName, Consumer<io.strimzi.api.kafka.model.Kafka> editor)
-
getKafkaTlsListenerCaCertName
public static String getKafkaTlsListenerCaCertName(String namespace, String clusterName, String listenerName)
-
getKafkaExternalListenerCaCertName
public static String getKafkaExternalListenerCaCertName(String namespace, String clusterName, String listenerName)
-
-