Class AvroConfiguration

    • Constructor Detail

      • AvroConfiguration

        public AvroConfiguration()
    • Method Detail

      • getHost

        public String getHost()
      • setHost

        public void setHost​(String host)
        Hostname to use
      • getPort

        public int getPort()
      • setPort

        public void setPort​(int port)
        Port number to use
      • getProtocol

        public org.apache.avro.Protocol getProtocol()
      • setProtocol

        public void setProtocol​(org.apache.avro.Protocol protocol)
        Avro protocol to use
      • setTransport

        public void setTransport​(String transport)
        Transport to use, can be either http or netty
      • setTransport

        public void setTransport​(AvroTransport transport)
        Transport to use, can be either http or netty
      • getProtocolLocation

        public String getProtocolLocation()
      • setProtocolLocation

        public void setProtocolLocation​(String protocolLocation)
        Avro protocol location
      • getProtocolClassName

        public String getProtocolClassName()
      • setProtocolClassName

        public void setProtocolClassName​(String protocolClassName)
        Avro protocol to use defined by the FQN class name
      • getMessageName

        public String getMessageName()
      • setMessageName

        public void setMessageName​(String messageName)
        The name of the message to send.
      • getUriAuthority

        public String getUriAuthority()
      • setUriAuthority

        public void setUriAuthority​(String uriAuthority)
        Authority to use (username and password)
      • isReflectionProtocol

        public boolean isReflectionProtocol()
      • setReflectionProtocol

        public void setReflectionProtocol​(boolean isReflectionProtocol)
        If protocol object provided is reflection protocol. Should be used only with protocol parameter because for protocolClassName protocol type will be auto detected
      • isSingleParameter

        public boolean isSingleParameter()
      • setSingleParameter

        public void setSingleParameter​(boolean singleParameter)
        If true, consumer parameter won't be wrapped into array. Will fail if protocol specifies more then 1 parameter for the message