Class Named

java.lang.Object
org.apache.kafka.streams.kstream.Named

public class Named extends Object
  • Field Details

    • name

      protected String name
  • Constructor Details

    • Named

      protected Named(Named named)
    • Named

      protected Named(String name)
  • Method Details

    • as

      public static Named as(String name)
      Create a Named instance with provided name.
      Parameters:
      name - the processor name to be used. If null a default processor name will be generated.
      Returns:
      A new Named instance configured with name
      Throws:
      TopologyException - if an invalid name is specified; valid characters are ASCII alphanumerics, '.', '_' and '-'.
    • withName

      public Named withName(String name)
    • validate

      protected static void validate(String name)