You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sj...@apache.org on 2021/05/04 18:09:55 UTC

[flink-statefun] branch master updated: [hotfix][docs] fix invalid module configuration

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

sjwiesman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git


The following commit(s) were added to refs/heads/master by this push:
     new 8ee8308  [hotfix][docs] fix invalid module configuration
8ee8308 is described below

commit 8ee830895f8fdf44012cd8cca3d607f04b301d30
Author: Seth Wiesman <sj...@gmail.com>
AuthorDate: Tue May 4 13:04:53 2021 -0500

    [hotfix][docs] fix invalid module configuration
    
    This closes #232
---
 docs/content/docs/deployment/module.md | 38 +++++++++++++++++++++++++++++-----
 1 file changed, 33 insertions(+), 5 deletions(-)

diff --git a/docs/content/docs/deployment/module.md b/docs/content/docs/deployment/module.md
index 6f82517..f321ab0 100644
--- a/docs/content/docs/deployment/module.md
+++ b/docs/content/docs/deployment/module.md
@@ -33,9 +33,37 @@ module:
   meta: 
     type: remote
   spec:
-    endpoints:  # function endpoints
-    ingresses:  # ingress definitions
-    egresses:   # egress definitions
+    endpoints:
+      meta:
+        kind: http
+      spec:
+        functions: com.example/*
+        urlPathTempalte: https://bar.foo.com/{function.name}
+    ingresses:
+      - ingress:
+        meta:
+          type: io.statefun.kafka/ingress
+          id: com.example/my-ingress
+        spec:
+          address: kafka-broker:9092
+          consumerGroupId: my-consumer-group
+          startupPosition:
+            type: earliest
+          topics:
+            - topic: message-topic
+              valueType: io.statefun.types/string
+              targets:
+                - com.example/greeter
+    egresses:
+      - egress:
+        meta:
+          type: io.statefun.kafka/egress
+          id: example/output-messages
+        spec:
+          address: kafka-broker:9092
+          deliverySemantic:
+            type: exactly-once
+            transactionTimeoutMillis: 100000
 ```
 
 ## Endpoint Definition
@@ -47,8 +75,8 @@ endpoints:
   - endpoint:
     meta: 
       kind: http
-      functions: com.example/*
     spec:
+      functions: com.example/*
       urlPathTemplate: https://bar.foo.com/{function.name}
 ```
 
@@ -222,7 +250,7 @@ endpoint:
 ## Ingress
 
 An ingress is an input point where data is consumed from an external system and forwarded to zero or more functions.
-It is defined via an identifier and specificiation.
+It is defined via an identifier and specification.
 
 An ingress identifier, similar to a function type, uniquely identifies an ingress by specifying its [input type]({{< ref "docs/sdk/appendix#types" >}}), a namespace, and a name.