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 Namedas(String name)Create a Named instance with provided name.protected static voidvalidate(String name)NamedwithName(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. Ifnulla default processor name will be generated.- Returns:
- A new
Namedinstance configured with name - Throws:
TopologyException- if an invalid name is specified; valid characters are ASCII alphanumerics, '.', '_' and '-'.
-
validate
protected static void validate(String name)
-
-