[rocketmq-streams] branch main updated: fix(common) modify name

[karp]

This is an automated email from the ASF dual-hosted git repository.

karp pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git


The following commit(s) were added to refs/heads/main by this push:
     new ded82a4f fix(common) modify name
     new d2b2f642 Merge pull request #217 from ni-ze/supportRsqldb
ded82a4f is described below

commit ded82a4f1e1b827fa65d2b1e5beb1bb4465dccad
Author: 维章 <uncleran...@gmail.com>
AuthorDate: Wed Sep 21 19:18:20 2022 +0800

    fix(common) modify name
---
 .../rocketmq/streams/client/transform/DataStream.java    |  7 -------
 .../streams/common/configure/ConfigureFileKey.java       | 16 ++++++++--------
 2 files changed, 8 insertions(+), 15 deletions(-)

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 8f9c315a..328947f6 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 @@ public class DataStream implements Serializable {
         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 0f7fcc58..fef876a6 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 @@ public interface ConfigureFileKey {
     /**
      * 数据库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 @@ public interface ConfigureFileKey {
     /**
      * 
如果需要兼容老规则引擎规则，且规则存储在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";
     /**
      *
      */