InternalNameProvider Contract

InternalNameProvider is the abstraction of internal name providers that give a new name for a processor or a store.

Table 1. InternalNameProvider Contract
Method Description

newProcessorName

String newProcessorName(String prefix)

Returns a name of a processor with the given prefix

Used when:

newStoreName

String newStoreName(String prefix)

Returns a name of a state store with the given prefix

Used when:

Note
InternalStreamsBuilder is the one and only known implementation of InternalNameProvider Contract in Kafka Streams.

results matching ""

    No results matching ""