KamenRiderKuuga opened a new issue, #19770:
URL: https://github.com/apache/pulsar/issues/19770

   ### Search before asking
   
   - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) 
and found nothing similar.
   
   
   ### Version
   
   standalone Pulsar cluster in Kubernetes with image tag 
apachepulsar/pulsar:2.10.2
   
   ### Minimal reproduce step
   
   This is all the code I use:
   ```java
   public static void main(String[] args) throws PulsarClientException, 
PulsarAdminException, InterruptedException {
       AuthenticationBasic auth = new AuthenticationBasic();
       auth.configure("{\"userId\":\"superuser\",\"password\":\"admin\"}");
       String serviceHttpUrl = "http://127.0.0.1:8080";;
       String serviceUrl = "pulsar://127.0.0.1:6650";
       String tenant = "demo-tenant";
       String namespace = "demo-tenant/demo-namespace";
       PulsarAdmin admin = 
PulsarAdmin.builder().serviceHttpUrl(serviceHttpUrl).authentication(auth).build();
       if (!admin.tenants().getTenants().contains(tenant)) {
           admin.tenants().createTenant(tenant, 
TenantInfo.builder().adminRoles(Set.of("superuser")).allowedClusters
       }
       if (!admin.namespaces().getNamespaces(tenant).contains(namespace)) {
           admin.namespaces().createNamespace(namespace);
       }
       PulsarClient pulsarClient = 
PulsarClient.builder().serviceUrl(serviceUrl).authentication(auth).build();
       Producer<String> producer = 
pulsarClient.newProducer(Schema.STRING).topic("persistent://" + namespace + 
"/lev
       producer.newMessage().value("demo-data").send();
       // wait for few seconds
       Thread.sleep(3000);
       // print the topics
       List<String> topics = admin.topics().getList(namespace);
       // the list of topics will be empty
       topics.forEach(System.out::println);
       producer = pulsarClient.newProducer(Schema.STRING).topic("persistent://" 
+ namespace + "/level1").create();
       producer.newMessage().value("demo-data").send();
       // wait for few seconds
       Thread.sleep(3000);
       topics = admin.topics().getList(namespace);
       // the list of topics is : 
["persistent://demo-tenant/demo-namespace/level1"]
       topics.forEach(System.out::println);
   }
   ```
   
   ### What did you expect to see?
   
   When I use the topic 
`persistent://demo-tenant/demo-namespace/level1/level2/level3`, I think I 
should also see it in the query results of topic list
   
   ### What did you see instead?
   
   I can only get the `persistent://demo-tenant/demo-namespace/level1` in the 
query results
   
   ### Anything else?
   
   #19752 
   
   ### Are you willing to submit a PR?
   
   - [ ] I'm willing to submit a PR!


-- 
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: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to