diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/Module.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/Module.java index 7b25b8c20..cec98cf2d 100644 --- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/Module.java +++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/Module.java @@ -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"; } } diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnectorConfig.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnectorConfig.java index 38c37f953..171830e2f 100644 --- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnectorConfig.java +++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnectorConfig.java @@ -353,7 +353,7 @@ protected SourceInfoStructMaker getSourceInfoStruc } @Override - public String getConnectorType() { - return Module.connectorName(); + public String getContextName() { + return Module.contextName(); } } diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleTaskContext.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleTaskContext.java index 2cd25ed58..4192d2bc6 100644 --- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleTaskContext.java +++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleTaskContext.java @@ -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); } }