BewareMyPower commented on issue #12455:
URL: https://github.com/apache/pulsar/issues/12455#issuecomment-957267965


   Yeah, I also found 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]


Reply via email to