alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-5563 Improved logging for connector CR deployment

Browse Source
This commit is contained in:
jcechace 2022-08-30 10:31:30 +03:00 committed by Jakub Cechacek
parent 8037c797e9
commit cf65a41eac
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-testing/debezium-testing-system/src/main/java/io/debezium/testing/system/tools/kafka/connectors/CustomResourceConnectorDeployer.java
View File

@ -74,8 +74,10 @@ private void waitForKafkaConnector(ConnectorConfigBuilder config) {
* @param name name of the connector
*/
private void waitForKafkaConnector(String name) {
LOGGER.info("Waiting for connector '" + name + "' to become ready.");
kafkaConnectorOperation()
.withName(name)
.waitUntilCondition(WaitConditions::kafkaReadyCondition, 5, MINUTES);
LOGGER.info("Connector '" + name + "' is ready.");
}
}