[
https://issues.apache.org/jira/browse/KAFKA-3573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15244831#comment-15244831
]
Igor Stepanov commented on KAFKA-3573:
--------------------------------------
Good point, found your code here:
https://github.com/apache/kafka/tree/trunk/connect/json/src/main/java/org/apache/kafka/connect/json
Existing implementation works with JsonNode, mine - with POJOs. You may check
the tests for details. Are you interested in such an approach?
P.S.: loved your idea of serializing directly to byte[] (avoiding the
intermediate String), so implemented the same approach.
> 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)
