Can Apache Beam start from a specified offset? ________________________________ [email protected]
发件人： [email protected]<mailto:[email protected]> 发送时间： 2019-11-28 11:32 收件人： user<mailto:[email protected]> 主题： How to store&read offset with kafkaio Hi， I want to store the offset in Oracle/Mysql, and then every time I start the real-time streaming task, I want this task to start consuming from the offset stored in Oracle/Mysql. I haven't seen how to manually store the offset and specify the offset to start consuming after reading the documentation. Can anyone help me ________________________________ [email protected]
