You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
My consume code is follows public class HrConsumeListener implements MessageListenerConcurrently { @Override public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> list, ConsumeConcurrentlyContext consumeConcurrentlyContext) { try { list.forEach(messageExt -> { System.out.println(messageExt); }); int i = 1/0; return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; }catch (Exception e){ System.out.println("消费失败,offset不移动"); return ConsumeConcurrentlyStatus.RECONSUME_LATER; } } }
When consum fails, consumOffset still moves,I don't think it should move,but why?
The text was updated successfully, but these errors were encountered:
My consume code is follows
public class HrConsumeListener implements MessageListenerConcurrently { @Override public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> list, ConsumeConcurrentlyContext consumeConcurrentlyContext) { try { list.forEach(messageExt -> { System.out.println(messageExt); }); int i = 1/0; return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; }catch (Exception e){ System.out.println("消费失败,offset不移动"); return ConsumeConcurrentlyStatus.RECONSUME_LATER; } } }
When consum fails, consumOffset still moves,I don't think it should move,but why?
The text was updated successfully, but these errors were encountered: