Skip to content

Commit

Permalink
[fix][test] Fix test testTransactionBufferMetrics (#22117)
Browse files Browse the repository at this point in the history
(cherry picked from commit 0fc9f44)
  • Loading branch information
liangyepianzhou authored and lhotari committed Feb 27, 2024
1 parent 4ca7b78 commit b10f9c8
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -210,6 +210,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 b10f9c8

Please sign in to comment.