Class KafkaConnectorResource
- java.lang.Object
-
- io.strimzi.systemtest.resources.crd.KafkaConnectorResource
-
public class KafkaConnectorResource extends Object
-
-
Field Summary
Fields Modifier and Type Field Description static StringPATH_TO_KAFKA_CONNECTOR_CONFIG
-
Constructor Summary
Constructors Constructor Description KafkaConnectorResource()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static io.strimzi.api.kafka.model.KafkaConnectorcreateAndWaitForReadiness(io.strimzi.api.kafka.model.KafkaConnector kafkaConnector)static io.strimzi.api.kafka.model.KafkaConnectorBuilderdefaultKafkaConnector(io.strimzi.api.kafka.model.KafkaConnector kafkaConnector, String name, String kafkaConnectClusterName, int maxTasks)static voiddeleteKafkaConnectorWithoutWait(String connectorName)static io.strimzi.api.kafka.model.KafkaConnectorBuilderkafkaConnector(String name)static io.strimzi.api.kafka.model.KafkaConnectorBuilderkafkaConnector(String name, String clusterName)static io.strimzi.api.kafka.model.KafkaConnectorBuilderkafkaConnector(String name, String clusterName, int maxTasks)static io.fabric8.kubernetes.client.dsl.MixedOperation<io.strimzi.api.kafka.model.KafkaConnector,io.strimzi.api.kafka.KafkaConnectorList,io.fabric8.kubernetes.client.dsl.Resource<io.strimzi.api.kafka.model.KafkaConnector>>kafkaConnectorClient()static io.strimzi.api.kafka.model.KafkaConnectorkafkaConnectorWithoutWait(io.strimzi.api.kafka.model.KafkaConnector kafkaConnector)static voidreplaceKafkaConnectorResource(String resourceName, Consumer<io.strimzi.api.kafka.model.KafkaConnector> editor)
-
-
-
Field Detail
-
PATH_TO_KAFKA_CONNECTOR_CONFIG
public static final String PATH_TO_KAFKA_CONNECTOR_CONFIG
-
-
Method Detail
-
kafkaConnectorClient
public static io.fabric8.kubernetes.client.dsl.MixedOperation<io.strimzi.api.kafka.model.KafkaConnector,io.strimzi.api.kafka.KafkaConnectorList,io.fabric8.kubernetes.client.dsl.Resource<io.strimzi.api.kafka.model.KafkaConnector>> kafkaConnectorClient()
-
kafkaConnector
public static io.strimzi.api.kafka.model.KafkaConnectorBuilder kafkaConnector(String name)
-
kafkaConnector
public static io.strimzi.api.kafka.model.KafkaConnectorBuilder kafkaConnector(String name, String clusterName)
-
kafkaConnector
public static io.strimzi.api.kafka.model.KafkaConnectorBuilder kafkaConnector(String name, String clusterName, int maxTasks)
-
defaultKafkaConnector
public static io.strimzi.api.kafka.model.KafkaConnectorBuilder defaultKafkaConnector(io.strimzi.api.kafka.model.KafkaConnector kafkaConnector, String name, String kafkaConnectClusterName, int maxTasks)
-
kafkaConnectorWithoutWait
public static io.strimzi.api.kafka.model.KafkaConnector kafkaConnectorWithoutWait(io.strimzi.api.kafka.model.KafkaConnector kafkaConnector)
-
deleteKafkaConnectorWithoutWait
public static void deleteKafkaConnectorWithoutWait(String connectorName)
-
createAndWaitForReadiness
public static io.strimzi.api.kafka.model.KafkaConnector createAndWaitForReadiness(io.strimzi.api.kafka.model.KafkaConnector kafkaConnector)
-
-