[KAFKA-2707] Make KStream processor names deterministic

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.10.0.0
• Assignee: Yasuhiro Matsuda
• Reporter: Yasuhiro Matsuda
• Created: 29/Oct/15 16:45
• Updated: 23/Nov/15 03:09
• Resolved: 02/Nov/15 22:35

Description

Currently KStream processor names are generated from AtomicInteger static member of KStreamImpl. It is incremented every time a new processor is created. The problem is the name depends on the usage history of its use in the same JVM, thus the corresponding processors may have different names in different processes. It makes it difficult to debug.