Metriche repository
- Star
- (24.849 star)
- Metriche merge PR
- (Merge medio 1g 1h) (4 PR mergiate in 30 g)
Descrizione
TDengine服务版本为3.3.6.13，使用如上方法进行数据订阅并拉取数据时会报错（509行），消费者配置如上图2。报错部分堆栈如下（jdbc驱动版本为3.7.1） Consumer error: readerIndex: 150996698, writerIndex: 30983 (expected: 0 <= readerIndex <= writerIndex <= capacity(30983)) java.lang.IndexOutOfBoundsException: readerIndex: 150996698, writerIndex: 30983 (expected: 0 <= readerIndex <= writerIndex <= capacity(30983)) at io.netty.buffer.AbstractByteBuf.checkIndexBounds(AbstractByteBuf.java:112) at io.netty.buffer.AbstractByteBuf.readerIndex(AbstractByteBuf.java:121) at com.taosdata.jdbc.ws.tmq.entity.FetchRawBlockResp.fetchBlockData(FetchRawBlockResp.java:516) at com.taosdata.jdbc.ws.tmq.entity.FetchRawBlockResp.parseBlockInfos(FetchRawBlockResp.java:155) at com.taosdata.jdbc.ws.tmq.WSConsumerResultSet.next(WSConsumerResultSet.java:90) at com.taosdata.jdbc.ws.tmq.WSConsumer.doPoll(WSConsumer.java:202) at com.taosdata.jdbc.ws.tmq.WSConsumer.poll(WSConsumer.java:228) at com.taosdata.jdbc.tmq.TaosConsumer.poll(TaosConsumer.java:93)
当jdbc驱动版本为3.3.3时，报错信息如下 Consumer error: newPosition > limit: (664423 > 4098) java.lang.IllegalArgumentException: newPosition > limit: (664423 > 4098) at java.base/java.nio.Buffer.createPositionException(Buffer.java:341) at java.base/java.nio.Buffer.position(Buffer.java:316) at java.base/java.nio.ByteBuffer.position(ByteBuffer.java:1516) at java.base/java.nio.ByteBuffer.position(ByteBuffer.java:267) at com.taosdata.jdbc.ws.tmq.entity.FetchRawBlockResp.skipSchema(FetchRawBlockResp.java:201) at com.taosdata.jdbc.ws.tmq.entity.FetchRawBlockResp.parseBlockInfos(FetchRawBlockResp.java:148) at com.taosdata.jdbc.ws.tmq.WSConsumerResultSet.next(WSConsumerResultSet.java:85) at com.taosdata.jdbc.ws.tmq.WSConsumer.doPoll(WSConsumer.java:146) at com.taosdata.jdbc.ws.tmq.WSConsumer.poll(WSConsumer.java:164) at com.taosdata.jdbc.tmq.TaosConsumer.poll(TaosConsumer.java:93)