leizhiyuan commented on issue #16979:
URL: https://github.com/apache/pulsar/issues/16979#issuecomment-1207857276
sometimes I can reproduce this in local machine
I print some log in messagelistener. It seems there has a bug in recent
change
```
2022-08-08T16:57:10,898 - ERROR -
[broker-topic-workers-OrderedExecutor-7-0:Commands@1859] -
[PersistentSubscription{topic=persistent://my-property/my-ns/cache-read,
name=sub-1}] [-1] Failed to parse message metadata
java.lang.IllegalArgumentException: Invalid unknonwn tag type: 3
at
org.apache.pulsar.common.api.proto.LightProtoCodec.skipUnknownField(LightProtoCodec.java:270)
~[classes/:?]
at
org.apache.pulsar.common.api.proto.MessageMetadata.parseFrom(MessageMetadata.java:1370)
~[classes/:?]
at
org.apache.pulsar.common.protocol.Commands.parseMessageMetadata(Commands.java:445)
~[classes/:?]
at
org.apache.pulsar.common.protocol.Commands.parseMessageMetadata(Commands.java:432)
~[classes/:?]
at
org.apache.pulsar.common.protocol.Commands.peekMessageMetadata(Commands.java:1854)
~[classes/:?]
at
org.apache.pulsar.common.protocol.Commands.peekAndCopyMessageMetadata(Commands.java:1873)
~[classes/:?]
at
org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers.trySendMessagesToConsumers(PersistentDispatcherMultipleConsumers.java:587)
~[classes/:?]
at
org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers.sendMessagesToConsumers(PersistentDispatcherMultipleConsumers.java:558)
~[classes/:?]
at
org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers.lambda$readEntriesComplete$6(PersistentDispatcherMultipleConsumers.java:548)
~[classes/:?]
at
org.apache.bookkeeper.mledger.util.SafeRun$1.safeRun(SafeRun.java:32)
~[classes/:?]
at
org.apache.bookkeeper.common.util.SafeRunnable.run(SafeRunnable.java:36)
~[bookkeeper-common-4.15.0.jar:4.15.0]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
~[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
~[?:?]
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
~[netty-common-4.1.77.Final.jar:4.1.77.Final]
at java.lang.Thread.run(Thread.java:833) ~[?:?]
2022-08-08T16:57:10,919 - ERROR -
[broker-topic-workers-OrderedExecutor-7-0:Commands@1859] -
[PersistentSubscription{topic=persistent://my-property/my-ns/cache-read,
name=sub-1}] [-1] Failed to parse message metadata
java.lang.IndexOutOfBoundsException: readerIndex(42) + length(4) exceeds
writerIndex(44): UnpooledDuplicatedByteBuf(ridx: 42, widx: 44, cap: 44/44,
unwrapped: UnpooledHeapByteBuf(ridx: 0, widx: 44, cap: 44/44))
at
io.netty.buffer.AbstractByteBuf.checkReadableBytes0(AbstractByteBuf.java:1442)
~[netty-buffer-4.1.77.Final.jar:4.1.77.Final]
at
io.netty.buffer.AbstractByteBuf.checkReadableBytes(AbstractByteBuf.java:1428)
~[netty-buffer-4.1.77.Final.jar:4.1.77.Final]
at io.netty.buffer.AbstractByteBuf.skipBytes(AbstractByteBuf.java:971)
~[netty-buffer-4.1.77.Final.jar:4.1.77.Final]
at
org.apache.pulsar.common.api.proto.LightProtoCodec.skipUnknownField(LightProtoCodec.java:267)
~[classes/:?]
at
org.apache.pulsar.common.api.proto.MessageMetadata.parseFrom(MessageMetadata.java:1370)
~[classes/:?]
at
org.apache.pulsar.common.protocol.Commands.parseMessageMetadata(Commands.java:445)
~[classes/:?]
at
org.apache.pulsar.common.protocol.Commands.parseMessageMetadata(Commands.java:432)
~[classes/:?]
at
org.apache.pulsar.common.protocol.Commands.peekMessageMetadata(Commands.java:1854)
~[classes/:?]
at
org.apache.pulsar.common.protocol.Commands.peekAndCopyMessageMetadata(Commands.java:1873)
~[classes/:?]
at
org.apache.pulsar.broker.service.AbstractBaseDispatcher.lambda$filterEntriesForConsumer$1(AbstractBaseDispatcher.java:117)
~[classes/:?]
at java.util.Optional.orElseGet(Optional.java:364) ~[?:?]
at
org.apache.pulsar.broker.service.AbstractBaseDispatcher.filterEntriesForConsumer(AbstractBaseDispatcher.java:115)
~[classes/:?]
at
org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers.trySendMessagesToConsumers(PersistentDispatcherMultipleConsumers.java:657)
~[classes/:?]
at
org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers.sendMessagesToConsumers(PersistentDispatcherMultipleConsumers.java:558)
~[classes/:?]
at
org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers.lambda$readEntriesComplete$6(PersistentDispatcherMultipleConsumers.java:548)
~[classes/:?]
at
org.apache.bookkeeper.mledger.util.SafeRun$1.safeRun(SafeRun.java:32)
~[classes/:?]
at
org.apache.bookkeeper.common.util.SafeRunnable.run(SafeRunnable.java:36)
~[bookkeeper-common-4.15.0.jar:4.15.0]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
~[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
~[?:?]
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
~[netty-common-4.1.77.Final.jar:4.1.77.Final]
at java.lang.Thread.run(Thread.java:833) ~[?:?]
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
