mirror of https://github.com/apache/kafka.git
				
				
				
			MINOR: Wait for embedded clusters to start before using them in Connect OffsetsApiIntegrationTest (#16286)
Reviewers: Greg Harris <greg.harris@aiven.io>
This commit is contained in:
		
							parent
							
								
									8b6013f851
								
							
						
					
					
						commit
						2fa2c72581
					
				|  | @ -143,6 +143,15 @@ public class OffsetsApiIntegrationTest { | |||
| 
 | ||||
|             result.start(); | ||||
| 
 | ||||
|             try { | ||||
|                 result.assertions().assertExactlyNumWorkersAreUp( | ||||
|                         NUM_WORKERS, | ||||
|                         "Workers did not complete startup in time" | ||||
|                 ); | ||||
|             } catch (InterruptedException e) { | ||||
|                 throw new RuntimeException("Interrupted while awaiting cluster startup", e); | ||||
|             } | ||||
| 
 | ||||
|             return result; | ||||
|         }); | ||||
|     } | ||||
|  |  | |||
		Loading…
	
		Reference in New Issue