Skip to content

Commit 2abc731

Browse files
Demogorgon314eolivelli
authored andcommitted
Fix flaky-test: KafkaNonPartitionedTopicTest.testNonPartitionedTopic (#1853)
Fix: #1852 ### Motivation When the topic has an active producer or consumer, then we are not able to delete the topic by using `admin.topics().delete(topic)`, we should force delete it. ### Modifications Use the force option to delete the topic in the test. (cherry picked from commit c3336be)
1 parent 7f6f04b commit 2abc731

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

tests/src/test/java/io/streamnative/pulsar/handlers/kop/KafkaNonPartitionedTopicTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -101,7 +101,7 @@ public void testNonPartitionedTopic() throws PulsarAdminException {
101101
.getConsumer().listTopics(Duration.ofSeconds(1));
102102
assertEquals(result.size(), 1);
103103
} finally {
104-
admin.topics().delete(topic);
104+
admin.topics().delete(topic, true);
105105
}
106106
}
107107

0 commit comments

Comments
 (0)