msg_consumer.py：新增ack机制