Class AbstractKafkaClient.Builder<SELF extends AbstractKafkaClient.Builder<SELF>>
- java.lang.Object
-
- io.strimzi.systemtest.kafkaclients.AbstractKafkaClient.Builder<SELF>
-
- Direct Known Subclasses:
BasicExternalKafkaClient.Builder,InternalKafkaClient.Builder,OauthExternalKafkaClient.Builder,TracingExternalKafkaClient.Builder
- Enclosing class:
- AbstractKafkaClient<C extends AbstractKafkaClient.Builder<C>>
public abstract static class AbstractKafkaClient.Builder<SELF extends AbstractKafkaClient.Builder<SELF>> extends Object
-
-
Constructor Summary
Constructors Constructor Description Builder()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description AbstractKafkaClient<?>build()SELFwithCertificateAuthorityCertificateName(String caCertName)SELFwithClusterName(String clusterName)SELFwithConsumerGroupName(String consumerGroup)SELFwithConsumerProperties(ConsumerProperties consumerProperties)SELFwithKafkaUsername(String kafkaUsername)SELFwithListenerName(String listenerName)SELFwithMessageCount(int messageCount)SELFwithNamespaceName(String namespaceName)SELFwithPartition(Integer partition)SELFwithProducerProperties(ProducerProperties producerProperties)SELFwithSecretPrefix(String secretPrefix)SELFwithSecurityProtocol(org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol)SELFwithTopicName(String topicName)
-
-
-
Method Detail
-
withMessageCount
public SELF withMessageCount(int messageCount)
-
withSecurityProtocol
public SELF withSecurityProtocol(org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol)
-
withCertificateAuthorityCertificateName
public SELF withCertificateAuthorityCertificateName(String caCertName)
-
withProducerProperties
public SELF withProducerProperties(ProducerProperties producerProperties)
-
withConsumerProperties
public SELF withConsumerProperties(ConsumerProperties consumerProperties)
-
build
public AbstractKafkaClient<?> build() throws InstantiationException
- Throws:
InstantiationException
-
-