Package org.apache.kafka.streams.kstream

Class Named

java.lang.Object

org.apache.kafka.streams.kstream.Named

public class Named
extends Object

Method Summary

Modifier and Type	Method	Description
static Named	as(String name)	Create a Named instance with provided name.
Named	withName(String name)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)