Class OauthExternalKafkaClient

    • Method Detail

      • 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 interface KafkaClientOperations
        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 interface KafkaClientOperations
        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 interface KafkaClientOperations
        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 interface KafkaClientOperations
        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()