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/07/27 08:56:19 UTC
[GitHub] [pulsar] sollecitom opened a new issue, #16818: [Java clients] Consumer should not try to establish a connection to the broker within its constructor
sollecitom opened a new issue, #16818:
URL: https://github.com/apache/pulsar/issues/16818
Java Pulsar Consumer should not try to establish a connection to the broker within its constructor.
Instead, it should delay attempting to do so until the first time `receive()` is invoked. At the moment it's hard to spin up an application if Pulsar is temporary unreachable. The `subscribe()` call blocks until it successfully connects, or throws exceptions. The async alternative, `subscribeAsync()` won't complete until the connection is established. The result is that the application can crash or fail to come up if Pulsar is temporary unreachable during boot time.
As an alternative, the `Consumer` should expose explicit `connect()` and `connectAsync()` functions, for users to manually establish the connection. A property could be used to maintain backwards compatibility, like `delayEstablishingConnectionUntilNeeded`, with a default of false, so that existing code continues to work fine.
In the context of reactive streams, it's particularly important that everything happens lazily when the stream is collected, not when it's generated.
--
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] sollecitom commented on issue #16818: [Java clients] Consumer should not try to establish a connection to the broker within its constructor
Posted by GitBox <gi...@apache.org>.
sollecitom commented on issue #16818:
URL: https://github.com/apache/pulsar/issues/16818#issuecomment-1229377726
I thought we were starting an email thread.
On Sun, 28 Aug 2022, 03:16 github-actions[bot], ***@***.***>
wrote:
> The issue had no activity for 30 days, mark with Stale label.
>
> —
> Reply to this email directly, view it on GitHub
> <https://github.com/apache/pulsar/issues/16818#issuecomment-1229358313>,
> or unsubscribe
> <https://github.com/notifications/unsubscribe-auth/ABJT2AUAGNBUVUFLVB3RECDV3LDWJANCNFSM54YYYYTQ>
> .
> You are receiving this because you were mentioned.Message ID:
> ***@***.***>
>
--
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 #16818: [Java clients] Consumer should not try to establish a connection to the broker within its constructor
Posted by GitBox <gi...@apache.org>.
github-actions[bot] commented on issue #16818:
URL: https://github.com/apache/pulsar/issues/16818#issuecomment-1229358313
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] sollecitom commented on issue #16818: [Java clients] Consumer should not try to establish a connection to the broker within its constructor
Posted by GitBox <gi...@apache.org>.
sollecitom commented on issue #16818:
URL: https://github.com/apache/pulsar/issues/16818#issuecomment-1229377726
I thought we were starting an email thread.
On Sun, 28 Aug 2022, 03:16 github-actions[bot], ***@***.***>
wrote:
> The issue had no activity for 30 days, mark with Stale label.
>
> —
> Reply to this email directly, view it on GitHub
> <https://github.com/apache/pulsar/issues/16818#issuecomment-1229358313>,
> or unsubscribe
> <https://github.com/notifications/unsubscribe-auth/ABJT2AUAGNBUVUFLVB3RECDV3LDWJANCNFSM54YYYYTQ>
> .
> You are receiving this because you were mentioned.Message ID:
> ***@***.***>
>
--
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] Technoboy- commented on issue #16818: [Java clients] Consumer should not try to establish a connection to the broker within its constructor
Posted by GitBox <gi...@apache.org>.
Technoboy- commented on issue #16818:
URL: https://github.com/apache/pulsar/issues/16818#issuecomment-1197556258
Good idea and what do you think? @codelipenghui @mattisonchao
If so, we can let @sollecitom send out a discussion email for this.
--
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] mattisonchao commented on issue #16818: [Java clients] Consumer should not try to establish a connection to the broker within its constructor
Posted by GitBox <gi...@apache.org>.
mattisonchao commented on issue #16818:
URL: https://github.com/apache/pulsar/issues/16818#issuecomment-1198332781
we can send out a discussion email for this.
--
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 #16818: [Java clients] Consumer should not try to establish a connection to the broker within its constructor
Posted by GitBox <gi...@apache.org>.
github-actions[bot] commented on issue #16818:
URL: https://github.com/apache/pulsar/issues/16818#issuecomment-1260309971
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