BewareMyPower edited a comment on issue #12455:
URL: https://github.com/apache/pulsar/issues/12455#issuecomment-957267965
Yeah, I also noticed it.
```
Caused by:
org.apache.pulsar.client.api.PulsarClientException$BrokerMetadataException: The
subscription
c-pulsar-cluster-1-fw-192.168.3.3-8080-function-metadata-tailer-reader-7223e8a3e9
of the topic persistent://public/functions/metadata gets the last message id
was failed
Failed to get batch size for entry java.lang.IllegalArgumentException:
Invalid unknonwn tag type: 6
at
org.apache.pulsar.client.api.PulsarClientException.unwrap(PulsarClientException.java:987)
~[org.apache.pulsar-pulsar-client-api-2.8.1.jar:2.8.1]
at
org.apache.pulsar.client.impl.ConsumerImpl.hasMessageAvailable(ConsumerImpl.java:1869)
~[org.apache.pulsar-pulsar-client-original-2.8.1.jar:2.8.1]
at
org.apache.pulsar.client.impl.ReaderImpl.hasMessageAvailable(ReaderImpl.java:168)
~[org.apache.pulsar-pulsar-client-original-2.8.1.jar:2.8.1]
at
org.apache.pulsar.functions.worker.FunctionMetaDataManager.initialize(FunctionMetaDataManager.java:109)
~[org.apache.pulsar-pulsar-functions-worker-2.8.1.jar:2.8.1]
at
org.apache.pulsar.functions.worker.PulsarWorkerService.start(PulsarWorkerService.java:496)
~[org.apache.pulsar-pulsar-functions-worker-2.8.1.jar:2.8.1]
at
org.apache.pulsar.broker.PulsarService.startWorkerService(PulsarService.java:1569)
~[org.apache.pulsar-pulsar-broker-2.8.1.jar:2.8.1]
at
org.apache.pulsar.broker.PulsarService.start(PulsarService.java:759)
~[org.apache.pulsar-pulsar-broker-2.8.1.jar:2.8.1]
```
It looks like there's something wrong with topic
`persistent://public/functions/metadata`. If you enabled Pulsar Functions
before enabling KoP, this topic might not contain the `BrokerEntryMetadata`
part. After enabling KoP, the reader of this topic might fail by
`ConsumerImpl.hasMessageAvailable`.
I'm not familiar with Pulsar Functions, it might take some time to look into
the reason.
--
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]
