Class TracingExternalKafkaClient
- java.lang.Object
-
- io.strimzi.systemtest.kafkaclients.AbstractKafkaClient<TracingExternalKafkaClient.Builder>
-
- io.strimzi.systemtest.kafkaclients.externalClients.TracingExternalKafkaClient
-
- All Implemented Interfaces:
KafkaClientOperations
public class TracingExternalKafkaClient extends AbstractKafkaClient<TracingExternalKafkaClient.Builder> implements KafkaClientOperations
The TracingKafkaClient for sending and receiving messages using tracing properties. The client is using an external listeners.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classTracingExternalKafkaClient.Builder
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StringgetServiceName()intreceiveMessagesPlain(long timeoutMs)Receiving plain messages with the selected clientintreceiveMessagesTls(long timeoutMs)Sending encrypted messages using Tls technology with the selected clientintsendMessagesPlain(long timeoutMs)Sending plain messages with the selected clientintsendMessagesTls(long timeoutMs)Sending encrypted messages using Tls technology with the selected clientTracingExternalKafkaClient.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 TracingExternalKafkaClient.Builder toBuilder()
-
sendMessagesPlain
public int sendMessagesPlain(long timeoutMs)
Description copied from interface:KafkaClientOperationsSending plain messages with the selected client- Specified by:
sendMessagesPlainin interfaceKafkaClientOperations- Parameters:
timeoutMs- timeout in milliseconds- Returns:
- count of messages
-
sendMessagesTls
public int sendMessagesTls(long timeoutMs)
Description copied from interface:KafkaClientOperationsSending encrypted messages using Tls technology with the selected client- Specified by:
sendMessagesTlsin interfaceKafkaClientOperations- Parameters:
timeoutMs- timeout in milliseconds- Returns:
- count of messages
-
receiveMessagesPlain
public int receiveMessagesPlain(long timeoutMs)
Description copied from interface:KafkaClientOperationsReceiving plain messages with the selected client- Specified by:
receiveMessagesPlainin interfaceKafkaClientOperations- Parameters:
timeoutMs- timeout in milliseconds- Returns:
- count of messages
-
receiveMessagesTls
public int receiveMessagesTls(long timeoutMs)
Description copied from interface:KafkaClientOperationsSending encrypted messages using Tls technology with the selected client- Specified by:
receiveMessagesTlsin interfaceKafkaClientOperations- Parameters:
timeoutMs- timeout in milliseconds- Returns:
- count of messages
-
getServiceName
public String getServiceName()
-
toString
public String toString()
- Overrides:
toStringin classAbstractKafkaClient<TracingExternalKafkaClient.Builder>
-
-