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

Simplify serde configuration by providing default serde names

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • 0.8.0
    • 0.9.0
    • container
    • 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.2.patch
          5 kB
          Yan Fang
        2. SAMZA-554.3.patch
          5 kB
          Yan Fang
        3. SAMZA-554.patch
          3 kB
          Yan Fang

        Activity

          People

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

            Dates

              Created:
              Updated:
              Resolved: