I don’t believe that you can do that but there are several other options, like using “withStartReadTime()” or specific group.id Have you seen this answer https://stackoverflow.com/a/50766439/10687325 ?
> On 2 Dec 2019, at 03:54, 郑 洁锋 <[email protected]> wrote: > > Can Apache Beam start from a specified offset? > > [email protected] <mailto:[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] <mailto:[email protected]>
