Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-2146

Expose physical name in StreamDescriptor

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.2
    • Component/s: None
    • Labels:
      None

      Description

      Currently, physical name attribute of a stream is not exposed to the end user with the exception of generic input descriptor. Within Samza, we default streamId to the stream name in the absence of physical name. Due to above mentioned behavior, applications that want to consume streams with the same name using different systems have to use roundabout hacks to achieve.

      1. Applications are forced to use GenericInputDescriptor to specify physical name even though their preferred InputDescriptor is available (e.g. KafkaInputDescriptor).
      2. Applications need to go back to configuration to specify the physical name to work around which defeats the purpose of descriptors.  

      The proposal is to expose `PhysicalName` of the stream in StreamDescriptor to the users so that they can override it for the above specified use cases.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                bharathkk Bharath Kumarasubramanian
                Reporter:
                bharathkk Bharath Kumarasubramanian
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m