Make PersistentTopicsBase some methods async

[Technoboy-]

Motivation

PersistentTopicsBase has some sync methods. Decide to make them async.
Volunteers wanted for this.

Methods

• createNonPartitionedTopic @Technoboy- [Broker] Make PersistentTopicsBase#internalCreateNonPartitionedTopic async. #14030
• updatePartitionedTopic @Technoboy- [Broker] Make PersistentTopicsBase#internalUpdatePartitionedTopic async #14141
• getPartitionedMetadata @Technoboy- [Broker] Make PersistentTopicsBase#internalGetPartitionedMetadata async #14153
• getPartitionedTopicList @mattisonchao [Issue 14013] Make PersistentTopics#getPartitionedTopicList to pure async. #14059
• getStats @mattisonchao [Issue 14013][broker] make getStats method async  #14048
• getInternalStats @mattisonchao [Issue 14013][broker] make getInternalStats method async  #14047
• getManagedLedgerInfo @shibd No need to do
• getBacklog @shibd Make getBacklog method async #14057
• getPermissionsOnTopic @liudezhi2098 [Broker]make getPermissionsOnTopic method async #14179
• grantPermissionsOnTopic @liudezhi2098 [Broker]make grantPermissionsOnTopic method async #14152
• revokePermissionsOnTopic @liudezhi2098 [Broker]make revokePermissionsOnTopic method async #14149
• skipMessages @liudezhi2098 [Broker]make internalSkipMessages method async #14045
• peekNthMessage @liudezhi2098 [Issue 14013][broker]make internalPeekNthMessage method async #14039
• examineMessage @RobertIndie [Broker] Make PersistentTopicsBase#internalExamineMessage async #14062
• terminate @RobertIndie [Broker] Make PersistentTopicsBase#terminate async #14064
• compactionStatus @RobertIndie [Broker] Make PersistentTopicsBase#internalCompactionStatus async #14066
• deleteTopic @RobertIndie [Broker] Make PersistentTopicsBase#internalDeleteTopic async #14069
• triggerOffload @HQebupt [Issue 14013][broker] make triggerOffload method async #14027
• offloadStatus @HQebupt [Issue 14013][broker] make triggerOffload method async #14027

[liudezhi2098]

getPermissionsOnTopic
grantPermissionsOnTopic
revokePermissionsOnTopic
skipMessages
peekNthMessage

[HQebupt]

I can fix some @Technoboy-

[Technoboy-]

I can fix some @Technoboy-

Thanks for your help. assigned.

[shibd]

Hi, I can fix some @Technoboy-

[HQebupt]

getPermissionsOnTopic
grantPermissionsOnTopic
revokePermissionsOnTopic
skipMessages
peekNthMessage

I can fix some of them. @liudezhi2098

[HQebupt]

@mattisonchao Can I fix getStats and getInternalStats ? Thanks in advance.

[shibd]

@Technoboy- Current getManagedLedgerInfo method are already async.

[RobertIndie]

• examineMessage @RobertIndie [Broker] Make PersistentTopicsBase#internalExamineMessage async #14062
• terminate @RobertIndie [Broker] Make PersistentTopicsBase#terminate async #14064
• compactionStatus @RobertIndie [Broker] Make PersistentTopicsBase#internalCompactionStatus async #14066
• deleteTopic @RobertIndie [Broker] Make PersistentTopicsBase#internalDeleteTopic async #14069

[lhotari]

PersistentTopicsBase has some sync methods. Decide to make them async.
Volunteers wanted for this.

@Technoboy- @codelipenghui @merlimat Why are these changes made? The issue description doesn't describe any problem, just a decision.

Since there are a lot of these sync -> async changes, it would be good to always open a discussion on the dev-mailing list to get a consensus of the problem that is being solved. In Apache Pulsar, we make all major decisions on the mailing list.

@Technoboy- Could you start a dev-mailing list thread on the topic which describes the problem, the assumptions and the solution? /cc @mattisonchao

[lhotari]

I didn't receive a reply to my questions. I have taken these sync->async changes to discussion on the mailing list in the 2.10.0 release thread. https://lists.apache.org/thread/ggsywqsvwpb1yw8wh490mp8mbgzgxch5 .

[lhotari]

@codelipenghui Thank you for replying on the mailing list in thread https://lists.apache.org/thread/tn7rt59cd1k724l4ytfcmzx1w2sbtw7l . I have followed up with PR #14320 .

[Technoboy-]

PersistentTopicsBase has some sync methods. Decide to make them async.
Volunteers wanted for this.

@Technoboy- @codelipenghui @merlimat Why are these changes made? The issue description doesn't describe any problem, just a decision.

Since there are a lot of these sync -> async changes, it would be good to always open a discussion on the dev-mailing list to get a consensus of the problem that is being solved. In Apache Pulsar, we make all major decisions on the mailing list.

@Technoboy- Could you start a dev-mailing list thread on the topic which describes the problem, the assumptions and the solution? /cc @mattisonchao

Hi, @lhotari , I have opened a DISCUSS #14365 for this. Sorry for the late response.

[github-actions]

The issue had no activity for 30 days, mark with Stale label.

[github-actions]

The issue had no activity for 30 days, mark with Stale label.

[Technoboy-]

All the tracked methods have been resolved.