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