This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-4.0 by this push:
     new 739b16ec706 [fix][build][branch-4.0] Fix checkstyle in 
BrokerServiceAutoTopicCreationTest
739b16ec706 is described below

commit 739b16ec7063d102be0862d32e473282cf62e491
Author: Lari Hotari <lhot...@apache.org>
AuthorDate: Thu Aug 28 23:16:25 2025 +0300

    [fix][build][branch-4.0] Fix checkstyle in 
BrokerServiceAutoTopicCreationTest
---
 .../BrokerServiceAutoTopicCreationTest.java        | 23 ++++++++++++----------
 1 file changed, 13 insertions(+), 10 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceAutoTopicCreationTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceAutoTopicCreationTest.java
index 89f30d68e21..916485823e2 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceAutoTopicCreationTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceAutoTopicCreationTest.java
@@ -470,9 +470,10 @@ public class BrokerServiceAutoTopicCreationTest extends 
BrokerTestBase{
         List<String> topics = 
admin.topics().getList(namespaceName).stream().filter(tp -> {
             return TopicName.get(tp).getPartitionedTopicName().equals(topic);
         }).toList();
-        List<String> partitionedTopicList = 
admin.topics().getPartitionedTopicList(namespaceName).stream().filter(tp -> {
-            return TopicName.get(tp).getPartitionedTopicName().equals(topic);
-        }).toList();
+        List<String> partitionedTopicList =
+                
admin.topics().getPartitionedTopicList(namespaceName).stream().filter(tp -> {
+                    return 
TopicName.get(tp).getPartitionedTopicName().equals(topic);
+                }).toList();
         assertEquals(topics.size(), 1);
         assertEquals(partitionedTopicList.size(), 0);
         producer.close();
@@ -503,10 +504,11 @@ public class BrokerServiceAutoTopicCreationTest extends 
BrokerTestBase{
         Producer<byte[]> producer  = 
pulsarClient.newProducer().topic(topic).create();
         List<String> topics = 
admin.topics().getList(namespaceName).stream().filter(tp -> {
             return TopicName.get(tp).getPartitionedTopicName().equals(topic);
-        }).toList();;
-        List<String> partitionedTopicList = 
admin.topics().getPartitionedTopicList(namespaceName).stream().filter(tp -> {
-            return TopicName.get(tp).getPartitionedTopicName().equals(topic);
-        }).toList();;
+        }).toList();
+        List<String> partitionedTopicList =
+                
admin.topics().getPartitionedTopicList(namespaceName).stream().filter(tp -> {
+                    return 
TopicName.get(tp).getPartitionedTopicName().equals(topic);
+                }).toList();
         PartitionedTopicMetadata partitionedTopicMetadata = 
admin.topics().getPartitionedTopicMetadata(topic);
         assertEquals(topics.size(), 4);
         assertEquals(partitionedTopicList.size(), 1);
@@ -534,9 +536,10 @@ public class BrokerServiceAutoTopicCreationTest extends 
BrokerTestBase{
         List<String> topics = 
admin.topics().getList(namespaceName).stream().filter(tp -> {
             return TopicName.get(tp).getPartitionedTopicName().equals(topic);
         }).toList();
-        List<String> partitionedTopicList = 
admin.topics().getPartitionedTopicList(namespaceName).stream().filter(tp -> {
-            return TopicName.get(tp).getPartitionedTopicName().equals(topic);
-        }).toList();
+        List<String> partitionedTopicList =
+                
admin.topics().getPartitionedTopicList(namespaceName).stream().filter(tp -> {
+                    return 
TopicName.get(tp).getPartitionedTopicName().equals(topic);
+                }).toList();
         PartitionedTopicMetadata partitionedTopicMetadata = 
admin.topics().getPartitionedTopicMetadata(topic);
         assertEquals(topics.size(), 2);
         assertEquals(partitionedTopicList.size(), 1);

Reply via email to