Package org.apache.kafka.streams.kstream
Class Named
- java.lang.Object
-
- org.apache.kafka.streams.kstream.Named
-
- Direct Known Subclasses:
NamedInternal
public class Named extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description protected java.lang.String
name
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static Named
as(java.lang.String name)
Create a Named instance with provided name.protected static void
validate(java.lang.String name)
Named
withName(java.lang.String name)
-
-
-
Constructor Detail
-
Named
protected Named(Named named)
-
Named
protected Named(java.lang.String name)
-
-
Method Detail
-
as
public static Named as(java.lang.String name)
Create a Named instance with provided name.- Parameters:
name
- the processor name to be used. Ifnull
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(java.lang.String name)
-
validate
protected static void validate(java.lang.String name)
-
-