Class VerifiableClient


  • public class VerifiableClient
    extends Object
    Class represent verifiable kafka client which keeps common features of kafka clients
    • Method Detail

      • getMessages

        public List<String> getMessages()
        Get of messages
        Returns:
        Json array of messages;
      • setArguments

        public void setArguments​(ClientArgumentMap args)
        Set arguments of kafka client
        Parameters:
        args - string array of arguments
      • run

        public boolean run​(long timeoutMs)
        Run client in sync mode
        Returns:
        exit status of client
      • stop

        public void stop()
        Method for stop client
      • getBootstrapServer

        public String getBootstrapServer()