Thank you! That fixed the problem.
On Thu, Dec 22, 2022, 3:40 AM yuxia wrote:
> Yes, your understanding is correct. To handle this, you can define a
> watermark strategy that will detect idleness and mark an input as idle.
> Please refer to these two documents[1][2] for more details.
>
> [1]
> h
Yes, your understanding is correct. To handle this, you can define a watermark
strategy that will detect idleness and mark an input as idle.
Please refer to these two documents[1][2] for more details.
[1]
https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/datastream/kaf
