update

etl-core/src/main/java/com/tzld/crawler/etl/mq/EtlMQConsumer.java

@@ -103,7 +103,7 @@ public class EtlMQConsumer {
                     param.setMessageId(message.getMessageId());
                     etlService.deal(param);
                     log.info("Deal done of message: {} from topic: {}, group: {}", message, topic, groupId);
-                    consumer.ackMessage(Collections.singletonList(message.getReceiptHandle()));
+//                    consumer.ackMessage(Collections.singletonList(message.getReceiptHandle()));
                 } catch (Exception e) {
                     log.error("Consume message from topic: {}, group: {} message: {} error", topic, groupId, message, e);
                 } finally {