Class PlainSaslTransportPlugin

java.lang.Object
org.apache.storm.security.auth.sasl.SaslTransportPlugin
org.apache.storm.security.auth.plain.PlainSaslTransportPlugin
All Implemented Interfaces:
Closeable, AutoCloseable, ITransportPlugin

@Deprecated public class PlainSaslTransportPlugin extends SaslTransportPlugin
Deprecated.
This should never be used except for testing. It provides no security at all. The password is hard coded, and even if it were not it is sent in plain text.
  • Field Details

  • Constructor Details

    • PlainSaslTransportPlugin

      public PlainSaslTransportPlugin()
      Deprecated.
  • Method Details

    • getServerTransportFactory

      protected org.apache.storm.thrift.transport.TTransportFactory getServerTransportFactory(boolean impersonationAllowed) throws IOException
      Deprecated.
      Description copied from class: SaslTransportPlugin
      Create the transport factory needed for serving. All subclass must implement this method.
      Specified by:
      getServerTransportFactory in class SaslTransportPlugin
      Parameters:
      impersonationAllowed - true if SASL impersonation should be allowed, else false.
      Returns:
      server transport factory
      Throws:
      IOException - on any error.
    • connect

      public org.apache.storm.thrift.transport.TTransport connect(org.apache.storm.thrift.transport.TTransport transport, String serverHost, String asUser) throws IOException, org.apache.storm.thrift.transport.TTransportException
      Deprecated.
      Description copied from interface: ITransportPlugin
      Connect to the specified server via framed transport.
      Parameters:
      transport - The underlying Thrift transport.
      serverHost - server host
      asUser - the user as which the connection should be established, and all the subsequent actions should be executed. Only applicable when using secure storm cluster. A null/blank value here will just indicate to use the logged in user.
      Throws:
      IOException
      org.apache.storm.thrift.transport.TTransportException