Class BasicExternalKafkaClient

    • Method Detail

      • 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:
        sendMessagesPlain in interface KafkaClientOperations
        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:
        sendMessagesTls in interface KafkaClientOperations
        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:
        receiveMessagesPlain in interface KafkaClientOperations
        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:
        receiveMessagesTls in interface KafkaClientOperations
        Parameters:
        timeoutMs - timeout in milliseconds
        Returns:
        received message count