SteNicholas commented on a change in pull request #18502:
URL: https://github.com/apache/flink/pull/18502#discussion_r791593327
##########
File path: docs/content.zh/docs/connectors/datastream/kafka.md
##########
@@ -176,6 +176,15 @@ env.fromSource(kafkaSource, new CustomWatermarkStrategy(),
"Kafka Source With Cu
```
[这篇文档]({{< ref "docs/dev/datastream/event-time/generating_watermarks.md"
>}})描述了如何自定义水印策略(```WatermarkStrategy```)。
+### Idleness
Review comment:
```suggestion
### 空闲
如果并行度高于分区数,Kafka Source
不会自动进入空闲状态。您将需要降低并行度或向水印策略添加空闲超时。如果在这段时间内没有记录在流的分区中流动,则该分区被视为“空闲”并且不会阻止下游操作符中水印的进度。
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]