This is an automated email from the ASF dual-hosted git repository.
sjwiesman pushed a commit to branch release-3.0
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
The following commit(s) were added to refs/heads/release-3.0 by this push:
new 1ae409e [hotfix] Add missing configuration to documentation
1ae409e is described below
commit 1ae409e41677f70290b8d57400736a4c44436965
Author: Seth Wiesman <[email protected]>
AuthorDate: Thu Apr 22 11:44:54 2021 -0500
[hotfix] Add missing configuration to documentation
---
docs/content/docs/deployment/configurations.md | 6 +++++
docs/content/docs/io-module/apache-kafka.md | 32 ++------------------------
docs/content/docs/io-module/aws-kinesis.md | 5 ++++
3 files changed, 13 insertions(+), 30 deletions(-)
diff --git a/docs/content/docs/deployment/configurations.md
b/docs/content/docs/deployment/configurations.md
index 271e752..a866225 100644
--- a/docs/content/docs/deployment/configurations.md
+++ b/docs/content/docs/deployment/configurations.md
@@ -69,5 +69,11 @@ These may be set through your job's ``flink-conf.yaml``.
<td>Memory</td>
<td>The number of bytes to use for in memory buffering of the
feedback channel, before spilling to disk.</td>
</tr>
+ <tr>
+ <td><h5>statefun.async.max-per-task</h5></td>
+ <td style="word-wrap: break-word;">1024</td>
+ <td>Integer</td>
+ <td>The max number of async operations per task before
backpressure is applied.</td>
+ </tr>
</tbody>
</table>
\ No newline at end of file
diff --git a/docs/content/docs/io-module/apache-kafka.md
b/docs/content/docs/io-module/apache-kafka.md
index 3f186eb..a700f17 100644
--- a/docs/content/docs/io-module/apache-kafka.md
+++ b/docs/content/docs/io-module/apache-kafka.md
@@ -182,33 +182,5 @@ deliverySemantic:
### Writing To Kafka
-Functions write directly to Kafka from their SDK context. See SDK specific
documentation for more details.
-
-{{< tabs "writer" >}}
-{{< tab "Python" >}}
-```python
[email protected](
- typename='com.example/greeter'
- specs=[ValueSpec(name='seen'), type=IntType])
-def fun(context: Context, message: Message):
- # todo
- pass
-```
-{{< /tab >}}
-{{< tab "Java" >}}
-```java
-public class Greeter implements StatefulFunction {
- @Override
- public CompletableFuture<Void> apply(Context context, Message message) {
- context.send(
- KafkaEgressBuilder.forEgress(GREETS_EGRESS)
- .withTopic("output-topic")
- .withKey(...)
- .withValue(...));
-
- return context.done();
- }
-}
-```
-{{< /tab >}}
-{{< /tabs >}}
\ No newline at end of file
+Functions write directly to Kafka from their SDK context.
+See SDK specific documentation for more details.
diff --git a/docs/content/docs/io-module/aws-kinesis.md
b/docs/content/docs/io-module/aws-kinesis.md
index fab9d39..c288d44 100644
--- a/docs/content/docs/io-module/aws-kinesis.md
+++ b/docs/content/docs/io-module/aws-kinesis.md
@@ -200,3 +200,8 @@ awsCredentials:
profileName: profile-name
profilePath: /path/to/profile/config
```
+
+### Writing To Kinesis
+
+Functions write directly to Kinesis from their SDK context.
+See SDK specific documentation for more details.
\ No newline at end of file
