You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@pulsar.apache.org by GitBox <gi...@apache.org> on 2022/12/09 14:19:00 UTC

[GitHub] [pulsar] neapolis123 created a discussion: Questions about Registering Schema

GitHub user neapolis123 created a discussion: Questions about Registering Schema

Hi, I just wanted to ask about what internal state does the producer take after failing to register the Schema because its incompatible( Line 592 in ProducerImp ) . From what I have understood the state does not change but then wouldn't be logical to just close the producer. Since going back to Ready state will just result in a deadlock of an endless loop of trying to register the schema.

I hope this is the right place to ask such a question.

GitHub link: https://github.com/apache/pulsar/discussions/18850

----
This is an automatically sent email for dev@pulsar.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@pulsar.apache.org

[GitHub] [pulsar] neapolis123 added a comment to the discussion: Questions about Registering Schema

Posted by GitBox <gi...@apache.org>.

GitHub user neapolis123 added a comment to the discussion: Questions about Registering Schema

I am writing my thesis about Pulsar and a part of it is to model producers and consumers as state machines. When the reading the code I couldn't figure out what state the producer assumes when going from Ready to RegisteringSchema and then the registering fails. Can you please refer to where in the source code is the state changed to "Failed" when the function tryRegisteringSchema catches an IncompatibleSchemaException in the ProducerImp class  ? 
I am sorry if this is not the appropriate place to discuss this. 
My email : spirovsk@gmail.com If you deem it better to discuss this privately.

GitHub link: https://github.com/apache/pulsar/discussions/18850#discussioncomment-4352510

----
This is an automatically sent email for dev@pulsar.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@pulsar.apache.org

[GitHub] [pulsar] Technoboy- added a comment to the discussion: Questions about Registering Schema

Posted by GitBox <gi...@apache.org>.

GitHub user Technoboy- added a comment to the discussion: Questions about Registering Schema

ClientCnx#sendGetOrCreateSchema will send the request to broker.  
ClientCnx#handleGetOrCreateSchemaResponse will handle the response.

GitHub link: https://github.com/apache/pulsar/discussions/18850#discussioncomment-4352511

----
This is an automatically sent email for dev@pulsar.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@pulsar.apache.org

[GitHub] [pulsar] neapolis123 added a comment to the discussion: Questions about Registering Schema

Posted by GitBox <gi...@apache.org>.

GitHub user neapolis123 added a comment to the discussion: Questions about Registering Schema

> ClientCnx#sendGetOrCreateSchema will send the request to broker.
> ClientCnx#handleGetOrCreateSchemaResponse will handle the response.

So what does ProducerImpl#tryRegistringSchema do ?

GitHub link: https://github.com/apache/pulsar/discussions/18850#discussioncomment-4352512

----
This is an automatically sent email for dev@pulsar.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@pulsar.apache.org

[GitHub] [pulsar] sijie added a comment to the discussion: Questions about Registering Schema

Posted by GitBox <gi...@apache.org>.

GitHub user sijie added a comment to the discussion: Questions about Registering Schema

If the schema is incompatible, creating a producer should fail. Did you see any problems?

GitHub link: https://github.com/apache/pulsar/discussions/18850#discussioncomment-4352509

----
This is an automatically sent email for dev@pulsar.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@pulsar.apache.org