Page History

...

User provided node name should follow the same restrictions that ones currently apply to state stores during the create of Materialized instance.

The Currently, the Materialized class relies on the static method Topic.validate()Topic#validate. This method ensure that a provided name only contains legal characters [a-zA-Z0-9._-] and have a maximum length of 249.

...

We propose to copy methods from Topic.validate to Named.validate in order to be able to Topic#validate into Named. This new method will be used validate both store names and node names using the same method. This also have the benefit . The benefit is to remove a dependency with the code core module.

In addition, in case of a bad name, the Materialized class will throw a TopologyException instead of InvalidTypeException while building the topologytopology in case of a unvalid name instead of InvalidTopicException .

Proposed Changes

• Implement the new interface NamedOperation and default class Named 
• Update all parameter class to implement NamedOperation : Produced Consumed Printed Joined Grouped Suppressed
• Overload methods stateless for classes KStreams, KTables, KGroupedStream, KGroupedTable, TimeWindowedKStream, TimeWindowedKTable
• The processor names specified by developer will be used in place of the static processor prefix. Statics prefixes will still be used if no custom processor name are specified.
• Processor names should follow the same restrictions as the topic names. So legal characters are [a-zA-Z0-9._-] and the maximum length us of 249.

Below is an application example : 

...