DBZ-3099 Make streaming MBean name configurable in tests
This commit is contained in:
parent
048530aeb8
commit
7394ecfd62
2
.github/workflows/mysql-legacy-workflow.yml
vendored
2
.github/workflows/mysql-legacy-workflow.yml
vendored
@ -45,4 +45,4 @@ jobs:
|
|||||||
restore-keys: |
|
restore-keys: |
|
||||||
${{ runner.os }}-maven-
|
${{ runner.os }}-maven-
|
||||||
- name: Check changes in Debezium Connector MYSQL
|
- name: Check changes in Debezium Connector MYSQL
|
||||||
run: 'mvn clean install -B -pl debezium-connector-mysql -am -Passembly -Dformat.formatter.goal=validate -Dformat.imports.goal=check -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dtest.argline="-Dinternal.implementation=legacy"'
|
run: 'mvn clean install -B -pl debezium-connector-mysql -am -Passembly -Dformat.formatter.goal=validate -Dformat.imports.goal=check -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dtest.argline="-Dinternal.implementation=legacy -Dtest.streaming.metrics.namespace=binlog"'
|
||||||
|
@ -271,11 +271,7 @@ private void waitForStreamingToStart() throws InterruptedException {
|
|||||||
waitForStreamingRunning("mysql", SERVER_NAME, getStreamingNamespace());
|
waitForStreamingRunning("mysql", SERVER_NAME, getStreamingNamespace());
|
||||||
}
|
}
|
||||||
|
|
||||||
private String getStreamingNamespace() {
|
protected static boolean isLegacy() {
|
||||||
return isLegacy() ? "binlog" : "streaming";
|
|
||||||
}
|
|
||||||
|
|
||||||
protected boolean isLegacy() {
|
|
||||||
return MySqlConnector.LEGACY_IMPLEMENTATION.equals(System.getProperty(MySqlConnector.IMPLEMENTATION_PROP, "new"));
|
return MySqlConnector.LEGACY_IMPLEMENTATION.equals(System.getProperty(MySqlConnector.IMPLEMENTATION_PROP, "new"));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -1052,7 +1052,7 @@ public static void waitForSnapshotToBeCompleted(String connector, String server)
|
|||||||
}
|
}
|
||||||
|
|
||||||
public static void waitForStreamingRunning(String connector, String server) throws InterruptedException {
|
public static void waitForStreamingRunning(String connector, String server) throws InterruptedException {
|
||||||
waitForStreamingRunning(connector, server, "streaming");
|
waitForStreamingRunning(connector, server, getStreamingNamespace());
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void waitForStreamingRunning(String connector, String server, String contextName) {
|
public static void waitForStreamingRunning(String connector, String server, String contextName) {
|
||||||
@ -1072,7 +1072,7 @@ public static void waitForConnectorShutdown(String connector, String server) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public static boolean isStreamingRunning(String connector, String server) {
|
public static boolean isStreamingRunning(String connector, String server) {
|
||||||
return isStreamingRunning(connector, server, "streaming");
|
return isStreamingRunning(connector, server, getStreamingNamespace());
|
||||||
}
|
}
|
||||||
|
|
||||||
public static boolean isStreamingRunning(String connector, String server, String contextName) {
|
public static boolean isStreamingRunning(String connector, String server, String contextName) {
|
||||||
@ -1091,10 +1091,14 @@ public static ObjectName getSnapshotMetricsObjectName(String connector, String s
|
|||||||
}
|
}
|
||||||
|
|
||||||
public static ObjectName getStreamingMetricsObjectName(String connector, String server) throws MalformedObjectNameException {
|
public static ObjectName getStreamingMetricsObjectName(String connector, String server) throws MalformedObjectNameException {
|
||||||
return getStreamingMetricsObjectName(connector, server, "streaming");
|
return getStreamingMetricsObjectName(connector, server, getStreamingNamespace());
|
||||||
}
|
}
|
||||||
|
|
||||||
public static ObjectName getStreamingMetricsObjectName(String connector, String server, String context) throws MalformedObjectNameException {
|
public static ObjectName getStreamingMetricsObjectName(String connector, String server, String context) throws MalformedObjectNameException {
|
||||||
return new ObjectName("debezium." + connector + ":type=connector-metrics,context=" + context + ",server=" + server);
|
return new ObjectName("debezium." + connector + ":type=connector-metrics,context=" + context + ",server=" + server);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
protected static String getStreamingNamespace() {
|
||||||
|
return System.getProperty("test.streaming.metrics.namespace", "streaming");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user