Keli
Keli
> hello,这些mvn包没法下载了,请问有新地址提供下载吗?   你先从 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 的消息都会重复投递,消费的幂等性是需要消费者自己处理的。