This message was deleted.

Yes

@jihong do you want to do it using the Java admin API or with the admin-cli ?

Java admin API

In that case you will have to use

admin.topicPolicies().setRetention(String topic, RetentionPolicies policies)

Yes, using the java admin api, thank you very much for your answer!

@Alexander Preuß, this is working, thanks a ton!! Sharing the solution snippet in the thread,

public void setTopicRetentionPolicy(
      Long tenantId,
      String tenantName,
      Env env,
      String namespaceName,
      String topicName,
      int retentionTimeInMinutes) {
    PulsarAdmin pulsarAdmin = getPulsarAdmin(tenantId, env, PulsarRole.ADMIN);
    RetentionPolicies policies = new RetentionPolicies(retentionTimeInMinutes, -1);
    pulsarAdmin
        .topicPolicies()
        .setRetention(getTopicName(tenantName, namespaceName, topicName), policies);
  }