Results 19 comments of Keli

> hello,这些mvn包没法下载了,请问有新地址提供下载吗? ![image](https://user-images.githubusercontent.com/58760465/202647264-c9eee0fa-3c05-400a-a29e-7bb9e2f5c072.png) ![image](https://user-images.githubusercontent.com/58760465/202647361-048e054b-ec80-4565-9b53-3fb29fe775b5.png) 你先从 maven 中心仓库这里搜索下载吧,之前的地址过期了。

consume queue 的推进并不依赖 pull log,而是每个 consumer group 都会维护一个当前的消费进度。每次一个 consumer 来拉取消息,都会从当前消费进度开始分配消息,然后将分配的消息记录到 pull log 中,consumer group 里每个 consumer 的 pull log 都是独立的。

@yuyijq 这个 SQL 变更语句你们那边还有么?

qschedule 目前没有开源计划。

目前是没有的。

https://github.com/qunarcorp/qmq/blob/22d691707122c41fa6676df367c64b677ecfd4a3/qmq-api/src/main/java/qunar/tc/qmq/Message.java#L136 通过设置这个 `autoAck` 来调整。

这里的服务器是你的消费者还是 qmq 的 broker? 消费者重启,没有 ack 的消息应该都会重发,除非消息已经过期了。 无论你的业务多么耗时,都是需要保证你的消费能力是要超过消息发送量的,否则消息肯定会不断堆积。同时消费耗时也不能超过设定的消息过期时间。

参考这里:https://github.com/qunarcorp/qmq/blob/master/docs/cn/install.md#%E9%85%8D%E7%BD%AE%E6%96%87%E4%BB%B6-1 ``` # 可选,动态生效,messagelog过期时间,单位是小时 messagelog.retention.hours=72 # 可选,动态生效,consumerlog过期时间 consumerlog.retention.hours=72 # 可选,动态生效,pulllog过期时间 pulllog.retention.hours=72 ```

qmq 服务端没有 ack 的消息都会重复投递,消费的幂等性是需要消费者自己处理的。