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

DBZ-1356 Define contextName

Browse Source
This commit is contained in:
Jiri Pechanec 2019-07-02 13:08:47 +02:00 committed by Gunnar Morling
parent 0154af0e38
commit f9daa53a21
3 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/Module.java
View File

@ -22,11 +22,17 @@ public static String version() {
return INFO.getProperty("version");
}
/**
* @return symbolic name of the connector plugin
*/
public static String name() {
return "oracle";
}
public static String connectorName() {
/**
* @return context name used in log MDC and JMX metrics
*/
public static String contextName() {
return "Oracle";
}
}

4
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnectorConfig.java
View File

@ -353,7 +353,7 @@ protected SourceInfoStructMaker<? extends AbstractSourceInfo> getSourceInfoStruc
}
@Override
public String getConnectorType() {
return Module.connectorName();
public String getContextName() {
return Module.contextName();
}
}

2
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleTaskContext.java
View File

@ -10,6 +10,6 @@
public class OracleTaskContext extends CdcSourceTaskContext {
public OracleTaskContext(OracleConnectorConfig config, OracleDatabaseSchema schema) {
super(config.getConnectorType(), config.getLogicalName(), schema::tableIds);
super(config.getContextName(), config.getLogicalName(), schema::tableIds);
}
}