[ https://issues.apache.org/jira/browse/KAFKA-1797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jun Rao updated KAFKA-1797: --------------------------- Attachment: kafka-1797_2014-12-09_18:48:33.patch > add the serializer/deserializer api to the new java client > ---------------------------------------------------------- > > Key: KAFKA-1797 > URL: https://issues.apache.org/jira/browse/KAFKA-1797 > Project: Kafka > Issue Type: Improvement > Components: core > Affects Versions: 0.8.2 > Reporter: Jun Rao > Assignee: Jun Rao > Attachments: kafka-1797.patch, kafka-1797_2014-12-09_18:48:33.patch > > > 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. -- This message was sent by Atlassian JIRA (v6.3.4#6332)