Class KafkaTopicResource
- java.lang.Object
-
- io.strimzi.systemtest.resources.crd.KafkaTopicResource
-
public class KafkaTopicResource extends Object
-
-
Field Summary
Fields Modifier and Type Field Description static StringPATH_TO_KAFKA_TOPIC_CONFIG
-
Constructor Summary
Constructors Constructor Description KafkaTopicResource()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static io.strimzi.api.kafka.model.KafkaTopiccreateAndWaitForReadiness(io.strimzi.api.kafka.model.KafkaTopic topic)static io.strimzi.api.kafka.model.KafkaTopicBuilderdefaultTopic(String clusterName, String topicName, int partitions, int replicas, int minIsr)static io.fabric8.kubernetes.client.dsl.MixedOperation<io.strimzi.api.kafka.model.KafkaTopic,io.strimzi.api.kafka.KafkaTopicList,io.fabric8.kubernetes.client.dsl.Resource<io.strimzi.api.kafka.model.KafkaTopic>>kafkaTopicClient()static voidreplaceTopicResource(String resourceName, Consumer<io.strimzi.api.kafka.model.KafkaTopic> editor)static io.strimzi.api.kafka.model.KafkaTopicBuildertopic(String clusterName, String topicName)static io.strimzi.api.kafka.model.KafkaTopicBuildertopic(String clusterName, String topicName, int partitions)static io.strimzi.api.kafka.model.KafkaTopicBuildertopic(String clusterName, String topicName, int partitions, int replicas)static io.strimzi.api.kafka.model.KafkaTopicBuildertopic(String clusterName, String topicName, int partitions, int replicas, int minIsr)static io.strimzi.api.kafka.model.KafkaTopictopicWithoutWait(io.strimzi.api.kafka.model.KafkaTopic kafkaTopic)
-
-
-
Field Detail
-
PATH_TO_KAFKA_TOPIC_CONFIG
public static final String PATH_TO_KAFKA_TOPIC_CONFIG
-
-
Method Detail
-
kafkaTopicClient
public static io.fabric8.kubernetes.client.dsl.MixedOperation<io.strimzi.api.kafka.model.KafkaTopic,io.strimzi.api.kafka.KafkaTopicList,io.fabric8.kubernetes.client.dsl.Resource<io.strimzi.api.kafka.model.KafkaTopic>> kafkaTopicClient()
-
topic
public static io.strimzi.api.kafka.model.KafkaTopicBuilder topic(String clusterName, String topicName)
-
topic
public static io.strimzi.api.kafka.model.KafkaTopicBuilder topic(String clusterName, String topicName, int partitions)
-
topic
public static io.strimzi.api.kafka.model.KafkaTopicBuilder topic(String clusterName, String topicName, int partitions, int replicas)
-
topic
public static io.strimzi.api.kafka.model.KafkaTopicBuilder topic(String clusterName, String topicName, int partitions, int replicas, int minIsr)
-
defaultTopic
public static io.strimzi.api.kafka.model.KafkaTopicBuilder defaultTopic(String clusterName, String topicName, int partitions, int replicas, int minIsr)
-
createAndWaitForReadiness
public static io.strimzi.api.kafka.model.KafkaTopic createAndWaitForReadiness(io.strimzi.api.kafka.model.KafkaTopic topic)
-
topicWithoutWait
public static io.strimzi.api.kafka.model.KafkaTopic topicWithoutWait(io.strimzi.api.kafka.model.KafkaTopic kafkaTopic)
-
-