Merge branch 'master' of github.com:apache/rocketmq-externals
* 'master' of github.com:apache/rocketmq-externals:
[rocketmq-connect-kafka]: Completion method KafkaSourceTask#pause(), KafkaSourceTask#resume(). (#854)
fix typo (#855)
diff --git a/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/Config.java b/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/Config.java
index fe5a90b..1a9bbc9 100644
--- a/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/Config.java
+++ b/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/Config.java
@@ -78,6 +78,9 @@
private long timestampDelayInterval = 0;
private String dbTimezone = "GMT+8";
private String queueName;
+ private String jdbcUrl;
+ private String jdbcUsername;
+ private String jdbcPassword;
private Logger log = LoggerFactory.getLogger(Config.class);
public static final Set<String> REQUEST_CONFIG = new HashSet<String>() {
@@ -323,4 +326,32 @@
public void setWhiteTable(String whiteTable) {
this.whiteTable = whiteTable;
}
+
+ public void setPollInterval(long pollInterval) {
+ this.pollInterval = pollInterval;
+ }
+
+ public String getJdbcUrl() {
+ return jdbcUrl;
+ }
+
+ public void setJdbcUrl(String jdbcUrl) {
+ this.jdbcUrl = jdbcUrl;
+ }
+
+ public String getJdbcUsername() {
+ return jdbcUsername;
+ }
+
+ public void setJdbcUsername(String jdbcUsername) {
+ this.jdbcUsername = jdbcUsername;
+ }
+
+ public String getJdbcPassword() {
+ return jdbcPassword;
+ }
+
+ public void setJdbcPassword(String jdbcPassword) {
+ this.jdbcPassword = jdbcPassword;
+ }
}
\ No newline at end of file
