Package org.apache.kafka.streams.kstream
Class Named
- java.lang.Object
-
- org.apache.kafka.streams.kstream.Named
-
public class Named extends Object
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static Named
as(String name)
Create a Named instance with provided name.protected static void
validate(String name)
Named
withName(String name)
-
-
-
Field Detail
-
name
protected String name
-
-
Method Detail
-
as
public static Named as(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 '-'.
-
validate
protected static void validate(String name)
-
-