Igor Stepanov created KAFKA-3573:
------------------------------------
Summary: 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)
