class KafkaToJavaSerializer implements Serializer<String, StratioStreamingMessage> {

    @Override
    public String deserialize(StratioStreamingMessage object) {
        return gson.toJson(object);
    }

    public  KafkaToJavaSerializer(Gson gson);

}