class LocationsHandler implements RequestHandler<KinesisEvent, List<String>> {

    private void write(Location location) {
        try {
            Futures.addCallback(
                    producer.addUserRecord(
                            streamName,
                            location.getAppUID(),
                            ByteBuffer.wrap(JsonUtils.write(location))),
                    callback);
        } catch (JsonProcessingException e) {
            logger.error("Can't prepare location for writing", e);
        }
    }

    public  LocationsHandler();

}