Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-1797

add the serializer/deserializer api to the new java client

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.8.2.0
    • Fix Version/s: 0.8.2.0
    • Component/s: core
    • Labels:
      None

      Description

      Currently, the new java clients take a byte array for both the key and the value. While this api is simple, it pushes the serialization/deserialization logic into the application. This makes it hard to reason about what type of data flows through Kafka and also makes it hard to share an implementation of the serializer/deserializer. For example, to support Avro, the serialization logic could be quite involved since it might need to register the Avro schema in some remote registry and maintain a schema cache locally, etc. Without a serialization api, it's impossible to share such an implementation so that people can easily reuse.

        Attachments

        1. kafka-1797.patch
          61 kB
          Jun Rao
        2. kafka-1797.patch
          64 kB
          Jun Rao
        3. kafka-1797.patch
          53 kB
          Jun Rao
        4. kafka-1797.patch
          3 kB
          Jun Rao
        5. kafka-1797_2014-12-17_09:47:45.patch
          86 kB
          Jun Rao
        6. kafka-1797_2014-12-15_15:36:24.patch
          102 kB
          Jun Rao
        7. kafka-1797_2014-12-09_18:48:33.patch
          84 kB
          Jun Rao

          Activity

            People

            • Assignee:
              junrao Jun Rao
              Reporter:
              junrao Jun Rao
              Reviewer:
              Neha Narkhede
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: