class KafkaToJavaSerializer implements Serializer<String, StratioStreamingMessage> {

    @Override
    public StratioStreamingMessage serialize(String object) {
        return gson.fromJson(object, StratioStreamingMessage.class);
    }

    public  KafkaToJavaSerializer(Gson gson);

}