Merge pull request #22 from ni-ze/quickStart

modify readme file and add dependency of channel-db and channel-es
alibaba · Jul 17, 2022 · 881d2d4 · 881d2d4
2 parents b1a08eb + 39c550d
commit 881d2d4
Show file tree

Hide file tree

Showing 4 changed files with 17 additions and 4 deletions.
diff --git a/docs/stream_source/kafka/README.md b/docs/stream_source/kafka/README.md
@@ -17,7 +17,7 @@ create table kafka_stream
       isJsonData = 'true',
       msgIsJsonArray = ‘ false ’,
       maxThread = '4',
-      maxFetchLogGroupSize = 100,
+      maxFetchLogGroupSize = '100',
       fieldDelimiter = '#',
       encoding = 'UTF-8'
       );
@@ -129,7 +129,7 @@ create table kafka_stream
       isJsonData = 'true',
       msgIsJsonArray = ‘ false ’,
       maxThread = '4',
-      maxFetchLogGroupSize = 100,
+      maxFetchLogGroupSize = '100',
       fieldDelimiter = '#',
       encoding = 'UTF-8'
       );

diff --git a/docs/stream_source/metaq/README.md b/docs/stream_source/metaq/README.md
@@ -17,7 +17,7 @@ create table metaq_stream
       isJsonData = 'true',
       msgIsJsonArray = ‘ false ’,
       maxThread = '4',
-      maxFetchLogGroupSize = 100,
+      maxFetchLogGroupSize = '100',
       fieldDelimiter = '#',
       encoding = 'UTF-8'
       );

diff --git a/docs/stream_source/rocketmq/README.md b/docs/stream_source/rocketmq/README.md
@@ -18,7 +18,7 @@ create table metaq_stream
       isJsonData = 'true',
       msgIsJsonArray = ‘ false ’,
       maxThread = '4',
-      maxFetchLogGroupSize = 100,
+      maxFetchLogGroupSize = '100',
       fieldDelimiter = '#',
       encoding = 'UTF-8'
       );

diff --git a/rsqldb-server/pom.xml b/rsqldb-server/pom.xml
@@ -17,6 +17,7 @@
     <properties>
         <maven.compiler.source>8</maven.compiler.source>
         <maven.compiler.target>8</maven.compiler.target>
+        <rocketmq-streams.version>1.0.2-preview-SNAPSHOT</rocketmq-streams.version>
     </properties>
 
 
@@ -49,6 +50,18 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
+
+        <!--这里加了以后才能使用ServiceLoaderComponent加载，否则找不到类-->
+        <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-streams-channel-db</artifactId>
+            <version>${rocketmq-streams.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-streams-channel-es</artifactId>
+            <version>${rocketmq-streams.version}</version>
+        </dependency>
     </dependencies>