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

Simplify serde configuration by providing default serde names

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: 0.8.0
    • Fix Version/s: 0.9.0
    • Component/s: container
    • Labels:
      None

      Description

      Currently we provide StringSerde, JsonSerde, IntegerSerde, etc out of box. In order to use them, we always need to set,

       serializers.registry.json.class=org.apache.samza.serializers.JsonSerdeFactory
       serializers.registry.string.class=org.apache.samza.serializers.StringSerdeFactory
       serializers.registry.integer.class=org.apache.samza.serializers.IntegerSerdeFactory
      

      then we can use the serde name "json"

      systems.kafka.samza.msg.serde=json
      

      I think it will be more convenient if the system looks for these default serde names (such as "string", "json", "integer", etc). Then users do not need to worry about putting these out-of-box serde factories in the "registry" part which is kinda error-prone.

      Of course, it still allows users to override the serde name if they want and throws exceptions when it can not find the serde factory.

        Attachments

        1. SAMZA-554.3.patch
          5 kB
          Yan Fang
        2. SAMZA-554.2.patch
          5 kB
          Yan Fang
        3. SAMZA-554.patch
          3 kB
          Yan Fang

          Activity

            People

            • Assignee:
              closeuris Yan Fang
              Reporter:
              closeuris Yan Fang
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: