-
Notifications
You must be signed in to change notification settings - Fork 3.5k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Attach names for all producers/readers in worker service #7165
Conversation
@srkukarni can you also add for the producer in the FunctionMetadataManager |
@jerrypeng Its already added. |
...nctions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionMetaDataManager.java
Show resolved
Hide resolved
@srkukarni that is the place. I must have missed it |
@@ -106,6 +106,7 @@ public SchedulerManager(WorkerConfig workerConfig, PulsarClient pulsarClient, Pu | |||
.blockIfQueueFull(true) | |||
.compressionType(CompressionType.LZ4) | |||
.sendTimeout(0, TimeUnit.MILLISECONDS) | |||
.producerName(config.getWorkerId() + "-scheduler-manager") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
can you also add
.subscriptionRolePrefix(workerConfig.getWorkerId())
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Producer name needs to be unique, so we better put this in the producer properties instead.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Actually, in this case it should be good since there's only 1 writer.
* Attach names for all producers/readers in worker service * Fix tests Co-authored-by: Sanjeev Kulkarni <sanjeevk@splunk.com>
* Attach names for all producers/readers in worker service * Fix tests Co-authored-by: Sanjeev Kulkarni <sanjeevk@splunk.com>
* Attach names for all producers/readers in worker service * Fix tests Co-authored-by: Sanjeev Kulkarni <sanjeevk@splunk.com>
(If this PR fixes a github issue, please add
Fixes #<xyz>
.)Fixes #
(or if this PR is one task of a github issue, please add
Master Issue: #<xyz>
to link to the master issue.)Master Issue: #
Motivation
This pr attaches names for all the producers/readers that worker service utilizes. This is very useful for debugging.
Modifications
Describe the modifications you've done.
Verifying this change
(Please pick either of the following options)
This change is a trivial rework / code cleanup without any test coverage.
(or)
This change is already covered by existing tests, such as (please describe tests).
(or)
This change added tests and can be verified as follows:
(example:)
Does this pull request potentially affect one of the following parts:
If
yes
was chosen, please highlight the changesDocumentation