BAEL-7199: Include feedback
This commit is contained in:
parent
fd9618cda6
commit
b8a6e4f89f
@ -83,5 +83,6 @@ public class KafkaDltRetryOnErrorIntegrationTest {
|
||||
|
||||
assertThat(mainTopicCountDownLatch.await(5, TimeUnit.SECONDS)).isTrue();
|
||||
assertThat(dlTTopicCountDownLatch.await(5, TimeUnit.SECONDS)).isTrue();
|
||||
assertThat(dlTTopicCountDownLatch.getCount()).isEqualTo(0);
|
||||
}
|
||||
}
|
@ -82,5 +82,6 @@ public class KafkaNoDltIntegrationTest {
|
||||
|
||||
assertThat(mainTopicCountDownLatch.await(5, TimeUnit.SECONDS)).isTrue();
|
||||
assertThat(dlTTopicCountDownLatch.await(5, TimeUnit.SECONDS)).isFalse();
|
||||
assertThat(dlTTopicCountDownLatch.getCount()).isEqualTo(1);
|
||||
}
|
||||
}
|
Loading…
x
Reference in New Issue
Block a user