馬老師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();
? ?}
標簽：
