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 class
OauthExternalKafkaClient.Builder
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getClientId()
String
getClientSecretName()
String
getIntrospectionEndpointUri()
String
getOauthTokenEndpointUri()
int
receiveMessagesPlain()
int
receiveMessagesPlain(long timeoutMs)
Receiving plain messages with the selected clientint
receiveMessagesTls()
int
receiveMessagesTls(long timeoutMs)
Sending encrypted messages using Tls technology with the selected clientint
sendMessagesPlain()
int
sendMessagesPlain(long timeoutMs)
Sending plain messages with the selected clientint
sendMessagesTls()
int
sendMessagesTls(long timeoutMs)
Sending encrypted messages using Tls technology with the selected clientOauthExternalKafkaClient.Builder
toBuilder()
String
toString()
-
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:KafkaClientOperations
Sending plain messages with the selected client- Specified by:
sendMessagesPlain
in interfaceKafkaClientOperations
- Parameters:
timeoutMs
- timeout in milliseconds- Returns:
- count of messages
-
sendMessagesTls
public int sendMessagesTls()
-
sendMessagesTls
public int sendMessagesTls(long timeoutMs)
Description copied from interface:KafkaClientOperations
Sending encrypted messages using Tls technology with the selected client- Specified by:
sendMessagesTls
in interfaceKafkaClientOperations
- Parameters:
timeoutMs
- timeout in milliseconds- Returns:
- count of messages
-
receiveMessagesPlain
public int receiveMessagesPlain()
-
receiveMessagesPlain
public int receiveMessagesPlain(long timeoutMs)
Description copied from interface:KafkaClientOperations
Receiving plain messages with the selected client- Specified by:
receiveMessagesPlain
in interfaceKafkaClientOperations
- Parameters:
timeoutMs
- timeout in milliseconds- Returns:
- count of messages
-
receiveMessagesTls
public int receiveMessagesTls()
-
receiveMessagesTls
public int receiveMessagesTls(long timeoutMs)
Description copied from interface:KafkaClientOperations
Sending encrypted messages using Tls technology with the selected client- Specified by:
receiveMessagesTls
in 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:
toString
in classAbstractKafkaClient<OauthExternalKafkaClient.Builder>
-
-