Class InternalKafkaClient

    • Method Detail

      • sendMessagesPlain

        public int sendMessagesPlain()
      • sendMessagesPlain

        public int sendMessagesPlain​(long timeout)
        Method for send messages to specific kafka cluster. It uses test-client API for communication with deployed clients inside kubernetes cluster
        Specified by:
        sendMessagesPlain in interface KafkaClientOperations
        Parameters:
        timeout - timeout in milliseconds
        Returns:
        count of send and acknowledged messages
      • sendMessagesTls

        public int sendMessagesTls()
      • sendMessagesTls

        public int sendMessagesTls​(long timeout)
        Description copied from interface: KafkaClientOperations
        Sending encrypted messages using Tls technology with the selected client
        Specified by:
        sendMessagesTls in interface KafkaClientOperations
        Parameters:
        timeout - timeout in milliseconds
        Returns:
        count of messages
      • receiveMessagesPlain

        public int receiveMessagesPlain()
      • receiveMessagesPlain

        public int receiveMessagesPlain​(long timeout)
        Description copied from interface: KafkaClientOperations
        Receiving plain messages with the selected client
        Specified by:
        receiveMessagesPlain in interface KafkaClientOperations
        Parameters:
        timeout - timeout in milliseconds
        Returns:
        count of messages
      • receiveMessagesTls

        public int receiveMessagesTls()
      • receiveMessagesTls

        public int receiveMessagesTls​(long timeoutMs)
        Method for receive messages from specific kafka cluster. It uses test-client API for communication with deployed clients inside kubernetes cluster
        Specified by:
        receiveMessagesTls in interface KafkaClientOperations
        Parameters:
        timeoutMs - timeout in milliseconds
        Returns:
        count of received messages
      • checkProducedAndConsumedMessages

        public void checkProducedAndConsumedMessages​(int producedMessages,
                                                     int consumedMessages)
      • assertSentAndReceivedMessages

        public void assertSentAndReceivedMessages​(int sent,
                                                  int received)
        Assert count of sent and received messages
        Parameters:
        sent - count of sent messages
        received - count of received messages
      • getPodName

        public String getPodName()