[SAMZA-1737] SystemProducers in TaskInstanceCollector do not resolve logical name (stream-id) to a physicalName if the configs for physical name are set

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Assignee: Unassigned
• Reporter: Sanil Jain
• Created: 30/May/18 19:03
• Updated: 25/Jun/18 17:46

Description

• A samza configuration streams.stream-id.samza.physical.name assigns a physical name which for example is actual name of a kafka topic
• If this config is set, the resolution of stream-id -> physicalName should occur in SystemProducers before TaskInstanceCollector dispatches the message
• Currently this works because most of the jobs use same stream-id and physicalName

Link: https://docs.google.com/document/d/1YQkhBwPw3Fl1NPt2rPQk2luCvaq0x4-BU1XqvfhazQk/edit?usp=sharing