Skip to content
This repository has been archived by the owner on Apr 1, 2024. It is now read-only.

Commit

Permalink
[fix][test] Fix test testTransactionBufferMetrics (apache#22117)
Browse files Browse the repository at this point in the history
  • Loading branch information
liangyepianzhou authored Feb 26, 2024
1 parent 31ed115 commit 0fc9f44
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -213,6 +213,8 @@ public void testAbortOnSubscription() throws ExecutionException, InterruptedExce

@Test
public void testTransactionBufferMetrics() throws Exception {
this.cleanup();
this.setup();
//Test commit
for (int i = 0; i < partitions; i++) {
String topic = partitionedTopicName.getPartition(i).toString();
Expand Down

0 comments on commit 0fc9f44

Please sign in to comment.