Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Fix: fix broken link #331

Merged
merged 1 commit into from
Feb 4, 2024
Merged

Fix: fix broken link #331

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion docs/connector/1-kafka.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -692,7 +692,7 @@ In `StreamPark` the `Kafka Producer` is called `KafkaSink`, which allows message

### Fault Tolerance and Semantics

After enabling Flink's `checkpointing`, `KafkaSink` can provide `once-exactly` semantic, please refer to Chapter 2 on [project configuration](/docs/development/conf/#checkpoints) for the specific setting of `checkpointing`.
After enabling Flink's `checkpointing`, `KafkaSink` can provide `once-exactly` semantic, please refer to Chapter 2 on [project configuration](/docs/development/config/#checkpoints) for the specific setting of `checkpointing`.

In addition to enabling checkpointing for Flink, you can also choose from three different modes by passing the appropriate `semantic` parameters to `KafkaSink`

Expand Down
2 changes: 1 addition & 1 deletion docs/connector/5-es.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -379,5 +379,5 @@ see the [official documentation](https://nightlies.apache.org/flink/flink-docs-r
### Apache StreamPark™ configuration

All other configurations must comply with the StreamPark configuration.
For [specific configurable](/docs/development/conf) items and the role of each parameter,
For [specific configurable](/docs/development/config) items and the role of each parameter,
please refer to the project configuration
2 changes: 1 addition & 1 deletion i18n/zh-CN/docusaurus-plugin-content-docs/current/connector/1-kafka.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -706,7 +706,7 @@ class JavaUser implements Serializable {

### 容错和语义

启用 Flink 的 `checkpointing` 后，`KafkaSink` 可以提供`精确一次`的语义保证,具体开启`checkpointing`的设置请参考第二章关于[项目配置](/docs/development/conf/#checkpoints)部分
启用 Flink 的 `checkpointing` 后，`KafkaSink` 可以提供`精确一次`的语义保证,具体开启`checkpointing`的设置请参考第二章关于[项目配置](/docs/development/config/#checkpoints)部分

除了启用 Flink 的 checkpointing，你也可以通过将适当的 `semantic` 参数传递给 `KafkaSink` 来选择三种不同的操作模式

Expand Down
2 changes: 1 addition & 1 deletion i18n/zh-CN/docusaurus-plugin-content-docs/current/connector/5-es.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -345,4 +345,4 @@ Elasticsearch 操作请求可能由于多种原因而失败，可以通过实现
### 配置内部批量处理器
es内部`BulkProcessor`可以进一步配置其如何刷新缓存操作请求的行为详细查看[官方文档](https://nightlies.apache.org/flink/flink-docs-release-1.14/zh/docs/connectors/datastream/elasticsearch/#elasticsearch-sink)**配置内部批量处理器** 单元
### Apache StreamPark™配置
其他的所有的配置都必须遵守 **StreamPark** 配置,具体可配置项和各个参数的作用请参考[项目配置](/docs/development/conf)
其他的所有的配置都必须遵守 **StreamPark** 配置,具体可配置项和各个参数的作用请参考[项目配置](/docs/development/config)
Loading