nsqJavaSDK

nsqJavaSDK copied to clipboard

com.youzan NSQ-Client 2.4.2.2-RELEASE jar

hhofchina

Non-resolvable parent POM and DCC-Client

1

hhofchina

teckick

请问可以配置一个负载的ip，指向集群所有的nsq的服务器吗

1

我的nsq集群在香港，欧美访问。 香港集群配置了一个负载的ip，欧美启动OK，但是心跳还是请求的nsq机器ip，导致一直报错。 请问可以指定一个ip访问nsq集群吗？或者现有配置可支持吗？ ConsumerImplV2, ConsumerImplV2.java, 272, run Throwable in keep connection process: com.tuya.nsq.client.exception.NSQLookupException: SDK can't get the right lookup info. 172.26.1.1:4161

bai020

LookupAddressUpdate not initialized if timeout in dcc first lookup

1

LookupAddressUpdate not initialized, once first lookup failed due to timeout

DoraALin

port back topic info from public class back to inner class in NSQMessage.

DoraALin

nsqd重启某个节点,producer会发送消息失败，重试3次均失败

2


tyutlt

2.4.2客户端消费数据出现netty解码错误

2

2018-07-23 18:13:48.381 [nioEventLoopGroup-11-1] WARN [{}] Uncaught exception in connection pipeline io.netty.handler.codec.DecoderException: java.lang.IndexOutOfBoundsException: readerIndex(8) + length(1034) exceeds writerIndex(1022): PooledUnsafeHeapByteBuf(ridx: 8, widx: 1022, cap: 1024) at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:98) ~[netty-all-4.0.56.Final.jar:4.0.56.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) [netty-all-4.0.56.Final.jar:4.0.56.Final] at...

duke88

NSQConfig使用clone后的扩展消息过滤数据存储map并没有真正clone，还是使用原来的map引用，后来查看源码内部的Map，好像并不支持clone. private Map consumePolicyMap = new ConcurrentHashMap();

duke88

Cosumer does not subscribe to the topic

2

When I use the 2.4.2 version to make Ordered message consumption, these do not subscribe to the topic

aaguerra