Skip to content

Commit f28ef80

Browse files
committed
test : add test
Signed-off-by: Su Ko <rhtn1128@gmail.com>
1 parent 63961e4 commit f28ef80

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spring-kafka/src/test/java/org/springframework/kafka/listener/TransactionalContainerTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1401,7 +1401,7 @@ void testFixTxOffsetsRetainsLeaderEpoch() throws Exception {
14011401
});
14021402

14031403
assertThat(latch.await(30, TimeUnit.SECONDS)).isTrue();
1404-
assertThat(committed.get().leaderEpoch()).isNotNull();
1404+
assertThat(committed.get().leaderEpoch().isPresent()).isTrue();
14051405
container.stop();
14061406
}
14071407

0 commit comments

Comments
 (0)