Class AbstractKafkaClient<C extends AbstractKafkaClient.Builder<C>>
- java.lang.Object
-
- io.strimzi.systemtest.kafkaclients.AbstractKafkaClient<C>
-
- Direct Known Subclasses:
BasicExternalKafkaClient,InternalKafkaClient,OauthExternalKafkaClient,TracingExternalKafkaClient
public abstract class AbstractKafkaClient<C extends AbstractKafkaClient.Builder<C>> extends Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classAbstractKafkaClient.Builder<SELF extends AbstractKafkaClient.Builder<SELF>>
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StringgetBootstrapServerFromStatus()StringgetCaCertName()StringgetConsumerGroup()ConsumerPropertiesgetConsumerProperties()StringgetKafkaUsername()StringgetListenerName()intgetMessageCount()IntegergetPartition()ProducerPropertiesgetProducerProperties()StringgetSecretPrefix()org.apache.kafka.common.security.auth.SecurityProtocolgetSecurityProtocol()StringgetTopicName()voidsetMessageCount(int messageCount)StringtoString()voidverifyProducedAndConsumedMessages(int producedMessages, int consumedMessages)
-
-
-
Method Detail
-
setMessageCount
public void setMessageCount(int messageCount)
-
verifyProducedAndConsumedMessages
public void verifyProducedAndConsumedMessages(int producedMessages, int consumedMessages)
-
getProducerProperties
public ProducerProperties getProducerProperties()
-
getConsumerProperties
public ConsumerProperties getConsumerProperties()
-
getBootstrapServerFromStatus
public String getBootstrapServerFromStatus()
-
getTopicName
public String getTopicName()
-
getPartition
public Integer getPartition()
-
getMessageCount
public int getMessageCount()
-
getConsumerGroup
public String getConsumerGroup()
-
getKafkaUsername
public String getKafkaUsername()
-
getSecurityProtocol
public org.apache.kafka.common.security.auth.SecurityProtocol getSecurityProtocol()
-
getCaCertName
public String getCaCertName()
-
getListenerName
public String getListenerName()
-
getSecretPrefix
public String getSecretPrefix()
-
-