马老师RocketMQ源码深入剖析
**/
ack.acknowledge();
} catch(FeignException | SocketException | KafkaException e) {
log.error("process error, could be retry: {}", message, e);
throw e;
} catch (Exception e) {
log.error("process error, discard: {}", message, e);
ack.acknowledge();
}
