weisd

Results 32 comments of weisd

是不是指定相同partitionKey的消息会存到同一个partition上,消费的时候就是顺序的了

顺序消费需要特别调用什么方法吗?

哦,了解 还有一个问题,如果要消费指定的数据怎么做的,我要记下每次消费的offset吗?

@absolute8511 如果我新加入一个consumer, 想从某个消息开始消费该怎么写呢

另外有几个问题: [https://github.com/youzan/nsq/blob/master/nsqdserver/context.go#L353](url) 这个接口,如果chan里一直有消息推送进来, 是不是会一直append到pubInfoList

[https://github.com/youzan/nsq/blob/master/consistence/nsqd_coordinator_cluster_write.go#L397](url) 每条推送消息会同步到所有ISR,半数以上成功才算成功,会不会慢呢

有序topic其实是把同一个hashkey的消息,存在一个partition, 如果用比如roomID作为key , 是不是所有连接这个roomID的用户都连接到了同一个partition上了,如果roomID对应用户很多的情况会不会影响性能

@absolute8511 谢谢解答,学习了

### 消息生产 (Golang, Java) Golang示例 ```Go topics := ["test_topic"] lookupAddress := "127.0.0.1:4161" config := nsq.NewConfig() // 启用顺序生产 config.EnableOrdered = true // 默认pub返回的id, offset, rawSize数据无效, 当需要跟踪或者调试的时候, 可以开启 // trace, 这时id, offset,...