wenbingshen commented on issue #676:
URL: 
https://github.com/apache/pulsar-client-go/issues/676#issuecomment-984309990


   Regarding another producerName: pulsar_s1-8-501 has 4 timelines on the 
broker log side:
   
   `pulsar_s1-8-501` with connection `ab.cde.138.8:16631` is sending data 
normally
   
![image](https://user-images.githubusercontent.com/35599757/144362886-2c79b663-5af7-42ef-9745-1f1f564b4365.png)
   
   The broker receives the request to add a producer from the new connection ` 
ab.cde.138.8:48277 ` for `pulsar_s1-8-501` , and because the  `channel id` of 
the producer is inconsistent, the old producer cannot be overwritten.
   
![image](https://user-images.githubusercontent.com/35599757/144363030-539c6dec-8d2f-44e0-9f6c-62fce3cb62be.png)
   
![image](https://user-images.githubusercontent.com/35599757/144363075-d4cd718b-17ee-4ff2-905c-2cbc7c96fb47.png)
   
![image](https://user-images.githubusercontent.com/35599757/144363386-ca21dddc-e599-438f-8f5c-291493c6076f.png)
   
![image](https://user-images.githubusercontent.com/35599757/144363432-de10e2ab-168f-43ee-a8bb-89b69b38174a.png)
   
   `pulsar_s1-8-501` is connected to `ab.cde.138.8:16631` and continues to send 
data normally
   
![image](https://user-images.githubusercontent.com/35599757/144363481-02e465a7-33ca-492e-965a-fa4ca0c525ef.png)
   
   Now the server has triggered `channelInactive` and started to close the 
connection `ab.cde.138.8:16631` related state, including producer information.
   
![image](https://user-images.githubusercontent.com/35599757/144363623-91df632e-5b29-4930-a55a-2f34393558d8.png)
   
![image](https://user-images.githubusercontent.com/35599757/144363882-c0fe0ad1-a227-4d74-ae3a-d96a03c9bd6f.png)
   
   Finally, the pulsar broker again receives the new connection 
`ab.cde.138.8:48277` for `pulsar_s1-8-501` request to add Producer, and 
successfully adds the Producer.
   
![image](https://user-images.githubusercontent.com/35599757/144364002-28d37ac1-8e96-4d23-9b2a-157f4431a918.png)
   
   
   
   


-- 
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