getTransformedMessage-Method.java

private KeyValue<String, Tuple<Throwable, OrderInputMsg>> getTransformedMessage(String key, OrderInputMsg value) {
    try{
        final OrderInputMsg msg = OrderProcessorService.processOrderMsg(value);
        final Tuple<Throwable, OrderInputMsg> inputMsgTuple = new Tuple<>(null, msg);
        return new KeyValue<>(key, inputMsgTuple);
    }catch (Exception e){
        final Tuple<Throwable, OrderInputMsg> inputMsgTuple = new Tuple<>(e, value);
        return new KeyValue<>(key, inputMsgTuple);
    }
}