Class OauthExternalKafkaClient
- java.lang.Object
-
- io.strimzi.systemtest.kafkaclients.AbstractKafkaClient<OauthExternalKafkaClient.Builder>
-
- io.strimzi.systemtest.kafkaclients.externalClients.OauthExternalKafkaClient
-
- All Implemented Interfaces:
KafkaClientOperations
public class OauthExternalKafkaClient extends AbstractKafkaClient<OauthExternalKafkaClient.Builder> implements KafkaClientOperations
The OauthExternalKafkaClient for sending and receiving messages using access token provided by authorization server. The client is using an external listeners.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classOauthExternalKafkaClient.Builder
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StringgetClientId()StringgetClientSecretName()StringgetIntrospectionEndpointUri()StringgetOauthTokenEndpointUri()intreceiveMessagesPlain()intreceiveMessagesPlain(long timeoutMs)Receiving plain messages with the selected clientintreceiveMessagesTls()intreceiveMessagesTls(long timeoutMs)Sending encrypted messages using Tls technology with the selected clientintsendMessagesPlain()intsendMessagesPlain(long timeoutMs)Sending plain messages with the selected clientintsendMessagesTls()intsendMessagesTls(long timeoutMs)Sending encrypted messages using Tls technology with the selected clientOauthExternalKafkaClient.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 OauthExternalKafkaClient.Builder toBuilder()
-
sendMessagesPlain
public int sendMessagesPlain()
-
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()
-
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()
-
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()
-
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
-
getClientId
public String getClientId()
-
getClientSecretName
public String getClientSecretName()
-
getOauthTokenEndpointUri
public String getOauthTokenEndpointUri()
-
getIntrospectionEndpointUri
public String getIntrospectionEndpointUri()
-
toString
public String toString()
- Overrides:
toStringin classAbstractKafkaClient<OauthExternalKafkaClient.Builder>
-
-