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.