Class BasicExternalKafkaClient
- java.lang.Object
-
- io.strimzi.systemtest.kafkaclients.AbstractKafkaClient<BasicExternalKafkaClient.Builder>
-
- io.strimzi.systemtest.kafkaclients.externalClients.BasicExternalKafkaClient
-
- All Implemented Interfaces:
KafkaClientOperations
public class BasicExternalKafkaClient extends AbstractKafkaClient<BasicExternalKafkaClient.Builder> implements KafkaClientOperations
The BasicExternalKafkaClient for sending and receiving messages with basic properties. The client is using an external listeners.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classBasicExternalKafkaClient.Builder
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description intreceiveMessagesPlain()intreceiveMessagesPlain(long timeoutMs)Receive messages to external entrypoint of the cluster with PLAINTEXT security protocol settingintreceiveMessagesTls()intreceiveMessagesTls(long timeoutMs)Receive messages to external entrypoint of the cluster with SSL security protocol settingintsendMessagesPlain()intsendMessagesPlain(long timeoutMs)Send messages to external entrypoint of the cluster with PLAINTEXT security protocol settingintsendMessagesTls()intsendMessagesTls(long timeoutMs)Send messages to external entrypoint of the cluster with SSL security protocol settingBasicExternalKafkaClient.BuildertoBuilder()StringtoString()-
Methods inherited from class io.strimzi.systemtest.kafkaclients.AbstractKafkaClient
getBootstrapServerFromStatus, getCaCertName, getConsumerGroup, getConsumerProperties, getKafkaUsername, getListenerName, getMessageCount, getPartition, getProducerProperties, getSecretPrefix, getSecurityProtocol, getTopicName, setMessageCount, verifyProducedAndConsumedMessages
-
-
-
-
Method Detail
-
toBuilder
public BasicExternalKafkaClient.Builder toBuilder()
-
sendMessagesPlain
public int sendMessagesPlain()
-
sendMessagesPlain
public int sendMessagesPlain(long timeoutMs)
Send messages to external entrypoint of the cluster with PLAINTEXT security protocol setting- Specified by:
sendMessagesPlainin interfaceKafkaClientOperations- Parameters:
timeoutMs- timeout in milliseconds- Returns:
- sent message count
-
sendMessagesTls
public int sendMessagesTls()
-
sendMessagesTls
public int sendMessagesTls(long timeoutMs)
Send messages to external entrypoint of the cluster with SSL security protocol setting- Specified by:
sendMessagesTlsin interfaceKafkaClientOperations- Parameters:
timeoutMs- timeout in milliseconds- Returns:
- sent message count
-
receiveMessagesPlain
public int receiveMessagesPlain()
-
receiveMessagesPlain
public int receiveMessagesPlain(long timeoutMs)
Receive messages to external entrypoint of the cluster with PLAINTEXT security protocol setting- Specified by:
receiveMessagesPlainin interfaceKafkaClientOperations- Parameters:
timeoutMs- timeout in milliseconds- Returns:
- received message count
-
receiveMessagesTls
public int receiveMessagesTls()
-
receiveMessagesTls
public int receiveMessagesTls(long timeoutMs)
Receive messages to external entrypoint of the cluster with SSL security protocol setting- Specified by:
receiveMessagesTlsin interfaceKafkaClientOperations- Parameters:
timeoutMs- timeout in milliseconds- Returns:
- received message count
-
toString
public String toString()
- Overrides:
toStringin classAbstractKafkaClient<BasicExternalKafkaClient.Builder>
-
-