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 
不会自动进入空闲状态。您将需要降低并行度或向水印策略添加空闲超时。如果在这段时间内没有记录在流的分区中流动,则该分区被视为“空闲”并且不会阻止下游操作符中水印的进度。
   
   [这篇文档]({{< ref "docs/dev/datastream/event-time/generating_watermarks.md" 
>}}#dealing-with-idle-sources) 描述了有关如何定义 ```WatermarkStrategy#withIdleness``` 
的详细信息.
   ```




-- 
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: issues-unsubscr...@flink.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to