Merge pull request #217 from ni-ze/supportRsqldb
fix(common) modify name
diff --git a/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/DataStream.java b/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/DataStream.java
index 8f9c315..328947f 100644
--- a/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/DataStream.java
+++ b/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/DataStream.java
@@ -563,13 +563,6 @@
return new DataStream(this.mainPipelineBuilder, this.otherPipelineBuilders, output);
}
-// public DataStream toKafka(String bootstrapServers, String topic) {
-// KafkaSink kafkaSink = new KafkaSink(bootstrapServers, topic);
-// ChainStage<?> output = this.mainPipelineBuilder.createStage(kafkaSink);
-// this.mainPipelineBuilder.setTopologyStages(currentChainStage, output);
-// return new DataStream(this.mainPipelineBuilder, this.otherPipelineBuilders, output);
-// }
-
public DataStream toEnhanceDBSink(String url, String userName, String password, String tableName) {
EnhanceDBSink sink = new EnhanceDBSink(url, userName, password, tableName);
ChainStage<?> output = this.mainPipelineBuilder.createStage(sink);
diff --git a/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configure/ConfigureFileKey.java b/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configure/ConfigureFileKey.java
index 0f7fcc5..fef876a 100644
--- a/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configure/ConfigureFileKey.java
+++ b/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configure/ConfigureFileKey.java
@@ -27,15 +27,15 @@
/**
* 数据库url
*/
- String DB_TYPE = "dipper.rds.jdbc.type";
- String JDBC_URL = "dipper.rds.jdbc.url";
- String JDBC_USERNAME = "dipper.rds.jdbc.username";
- String JDBC_PASSWORD = "dipper.rds.jdbc.password";
+ String DB_TYPE = "jdbc.type";
+ String JDBC_URL = "jdbc.url";
+ String JDBC_USERNAME = "jdbc.username";
+ String JDBC_PASSWORD = "jdbc.password";
String LEASE_CONSISTENT_HASH_SUFFIX = "dipper.lease.consistent.hash.suffix";
- String JDBC_DRIVER = "dipper.rds.jdbc.driver";
- String JDBC_TABLE_NAME = "dipper.rds.table.name";
+ String JDBC_DRIVER = "jdbc.driver";
+ String JDBC_TABLE_NAME = "table.name";
String SECRECY = "dipper.configure.sec.key";
- String SECRECY_DEFAULT = "93ea4211-6218-4353-b9cd-1d21618dbf4e";
+ String SECRECY_DEFAULT = "";
/**
* 情报的连接信息
@@ -68,7 +68,7 @@
/**
* 如果需要兼容老规则引擎规则，且规则存储在ruleengine_configure中时，设置为true。如果老规则迁移到了dipper_configure, 这个值不需要设置或设置成false即可。兼容老的规则引擎，老规则引擎的namespace 是name_space需要通过这个配置告诉resource做适配。
*/
- String JDBC_COMPATIBILITY_OLD_RULEENGINE = "dipper.rds.compatibility.old.ruleengine";
+ String JDBC_COMPATIBILITY_OLD_RULEENGINE = "mysql.compatibility.old.ruleengine";
/**
*
*/
