Merge branch 'master' of github.com:apache/rocketmq-externals
* 'master' of github.com:apache/rocketmq-externals:
[ISSUE #821] Support auto create subGroup (#828)
[rocketmq-replicator] Support subGroup whitelist (#843)
[rocketmq-replicator] Fix topic build route logic (#834)
[rocketmq-replicator] Bug fix: Missing subscription group when syncing offset (#837)
[ISSUE #824] Add WorkerDirectTask (#825)
[rocketmq-replicator] Support ACL (#832)
[rocketmq-connect] support acl
[ISSUE #822] Update .travis.yml (#823)
[rocketmq-connect] fix checkstyle (#818)
Update README.md
Remove it
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
