You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by "marble.zhong@coinflex.com.INVALID" <ma...@coinflex.com.INVALID> on 2020/10/14 08:12:21 UTC

kafka table connector保留多久的数据

你好， 用kafka table
connector接过来的数据，在flink这边会保留多久，在参数列表里没有看到有这个设置，如果保留太久，内存会撑暴，比如我只想保留半个小时，之前的数据可以清除。



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: kafka table connector保留多久的数据

Posted by Xiao Xu <ff...@gmail.com>.

flink 是不会保留数据的, 数据都是落盘在 kafka 里, flink 根据 offset 去读 kafka 里的数据, 可以设置 kafka
里留存的时间

marble.zhong@coinflex.com.INVALID <ma...@coinflex.com.invalid>
于2020年10月14日周三 下午4:37写道：

> 你好， 用kafka table
>
> connector接过来的数据，在flink这边会保留多久，在参数列表里没有看到有这个设置，如果保留太久，内存会撑暴，比如我只想保留半个小时，之前的数据可以清除。
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/