File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
modules/kafka/src/test/java/org/testcontainers/containers Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change 1313import org .junit .Test ;
1414import org .rnorth .ducttape .unreliables .Unreliables ;
1515
16+ import java .time .Duration ;
1617import java .util .Arrays ;
1718import java .util .UUID ;
1819import java .util .concurrent .TimeUnit ;
@@ -100,7 +101,7 @@ protected void testKafkaFunctionality(String bootstrapServers) throws Exception
100101 producer .send (new ProducerRecord <>(topicName , "testcontainers" , "rulezzz" )).get ();
101102
102103 Unreliables .retryUntilTrue (10 , TimeUnit .SECONDS , () -> {
103- ConsumerRecords <String , String > records = consumer .poll (100 );
104+ ConsumerRecords <String , String > records = consumer .poll (Duration . ofMillis ( 100 ) );
104105
105106 if (records .isEmpty ()) {
106107 return false ;
You can’t perform that action at this time.
0 commit comments