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);