|
@@ -103,7 +103,6 @@ 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()));
|
|
|
} catch (Exception e) {
|
|
|
log.error("Consume message from topic: {}, group: {} message: {} error", topic, groupId, message, e);
|
|
|
} finally {
|