[ https://issues.apache.org/jira/browse/KAFKA-3573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Igor Stepanov resolved KAFKA-3573. ---------------------------------- Resolution: Invalid > JSON (de)serialization for kafka-client > --------------------------------------- > > Key: KAFKA-3573 > URL: https://issues.apache.org/jira/browse/KAFKA-3573 > Project: Kafka > Issue Type: New Feature > Components: clients > Reporter: Igor Stepanov > > I've implemented generic implementations for: > - org.apache.kafka.common.serialization.Serializer > - org.apache.kafka.common.serialization.Deserializer > They provide support for serializing & deserializing POJO-entities into JSON > using: > - com.fasterxml.jackson.core:jackson-core > - com.fasterxml.jackson.core:jackson-databind > - org.apache.kafka.common.serialization.StringSerializer > - org.apache.kafka.common.serialization.StringDeserializer > The code is shared as a separate project on github: > https://github.com/stepio/kafka-json > But I may create a pull request for kafka-client to include this > implementation to the main code. What do you think? -- This message was sent by Atlassian JIRA (v6.3.4#6332)