freedba

HandleMessage回调函数消费的问题

1

我在回调函数里设置通道缓冲大小是1，通道缓冲消费完这一条后，立即调用Consumer.Stop()，这时我查看队列的数据少了有20条，请问多消费的消息是不是丢了？谢谢！

consumer.Stop() 阻塞问题

2

各位大佬： 我在调用consumer.Stop() 时遇到了阻塞，有没有办法加个超时？谢谢！

topic在集群里的迁移时间

2

请问下topicA在集群里的一个nsqd节点A上，如果Ａ挂了，如何能快速迁移到新节点上？ 我这边测试下来需要３分钟，才能在另外的节点上看到topicA。 谢谢！

large file create metadata is too slow

3

# ./dcp -v ../guest.vdi dcp DEBUG Creating dat archive. dcp DEBUG Connecting to dat network. dcp DEBUG Creating metadata for files: guest.vdi [=======---------------------------------] 17% | 8m14s | 5.05/29.46GB creating metadata...

INFO: 127.0.0.1:52574 - "DELETE /mcp/ HTTP/1.1" 200 OK [05/28/25 12:07:55] INFO HTTP Request: POST http://127.0.0.1:10003/mcp "HTTP/1.1 307 Temporary Redirect" _client.py:1740 INFO HTTP Request: POST http://127.0.0.1:10003/mcp "HTTP/1.1 307 Temporary Redirect" _client.py:1740...