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

DBZ-7373 Fix deploy return value in DockerKafkaConnectController

Browse Source
This commit is contained in:
Jiri Novotny 2024-01-24 09:30:08 +01:00 committed by Jiri Pechanec
parent 87ef90de2c
commit 09e8f7e1b7
2 changed files with 4 additions and 3 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/DockerKafkaConnectController.java
View File

@ -111,7 +111,7 @@ public HttpUrl getMetricsURL() {
@Override
public boolean undeploy() {
container.stop();
return container.isRunning();
return !container.isRunning();
}
@Override

5
debezium-testing/debezium-testing-system/src/main/java/io/debezium/testing/system/tools/kafka/DockerKafkaController.java
View File

@ -9,14 +9,15 @@
import static java.util.concurrent.TimeUnit.MINUTES;
import static org.awaitility.Awaitility.await;
import lombok.Getter;
import lombok.Setter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import io.debezium.testing.system.tools.kafka.docker.KafkaContainer;
import io.debezium.testing.system.tools.kafka.docker.ZookeeperContainer;
import lombok.Getter;
import lombok.Setter;
/**
* This class provides control over Kafka instance deployed as DockerContainer
*