Package org.apache.kafka.streams.kstream

Class Named

java.lang.Object

org.apache.kafka.streams.kstream.Named

public class Named
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected String	name

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Named(String name)
protected	Named(Named named)

Method Summary

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)

Methods inherited from class java.lang.Object

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

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)