You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2022/04/06 16:33:44 UTC
[GitHub] [pulsar] poorbarcode opened a new issue, #15050: Broker registed the same consumers
poorbarcode opened a new issue, #15050:
URL: https://github.com/apache/pulsar/issues/15050
**Describe the bug**
`ServerCnx.handleSubscribe` is not thread safety, when more than one request, problem occured: "broker registed the same consumers"
**To Reproduce**
Steps to reproduce the behavior:
1. The code files are in the attachment
2. copy `SubscribeProcessController.java` -> ${PULSAR_HOME}/pulsar-broker/src/main/java/org/apache/pulsar/
3. override file `ServerCnx.java` and `ConsumerImpl.java`
4. start broker
5. run this code
```
PulsarClient client = PulsarClient.builder()serviceUrl("pulsar://localhost:6650").build();
Consumer consumer = client.newConsumer().topic("my-topic").subscriptionName("my-subscription").subscribe();
```
6. see error log at `SubscribeProcessController.consumerAddFinished`
**Expected behavior**
see #14970
[SubscribeProcessController.java.txt](https://github.com/apache/pulsar/files/8428751/SubscribeProcessController.java.txt)
[ServerCnx.java.txt](https://github.com/apache/pulsar/files/8428750/ServerCnx.java.txt)
[ConsumerImpl.java.txt](https://github.com/apache/pulsar/files/8428748/ConsumerImpl.java.txt)
[log at SubscribeProcessController.txt](https://github.com/apache/pulsar/files/8428749/log.at.SubscribeProcessController.txt)
--
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: commits-unsubscribe@pulsar.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] github-actions[bot] commented on issue #15050: Broker registered the same consumers
Posted by GitBox <gi...@apache.org>.
github-actions[bot] commented on issue #15050:
URL: https://github.com/apache/pulsar/issues/15050#issuecomment-1148116487
The issue had no activity for 30 days, mark with Stale label.
--
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] github-actions[bot] commented on issue #15050: Broker registered the same consumers
Posted by GitBox <gi...@apache.org>.
github-actions[bot] commented on issue #15050:
URL: https://github.com/apache/pulsar/issues/15050#issuecomment-1120334260
The issue had no activity for 30 days, mark with Stale label.
--
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] poorbarcode commented on issue #15050: Broker registered the same consumers
Posted by GitBox <gi...@apache.org>.
poorbarcode commented on issue #15050:
URL: https://github.com/apache/pulsar/issues/15050#issuecomment-1154971688
fixed by #15051
--
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] poorbarcode closed issue #15050: Broker registered the same consumers
Posted by GitBox <gi...@apache.org>.
poorbarcode closed issue #15050: Broker registered the same consumers
URL: https://github.com/apache/pulsar/issues/15050
--
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org