BQ4jZYO6p5X9Tjnzow_pVJrKZA9dJkdRzqerg$
> > > > >
> > > > for EOS, which shows you how to reset the state while aborting
> ongoing
> > > > transactions.
> > > >
> > > > On Thu, Feb 18, 2021 at 11:01 AM Gary Russell
> > > wro
ssell
> > wrote:
> > >
> > > > You have to perform seeks (using the consumer) to the lowest
> > unprocessed
> > > > offset for each partition returned by the poll, before the next poll.
> > > >
> > > > From: Peter Cipov
>
to the lowest
> unprocessed
> > > offset for each partition returned by the poll, before the next poll.
> > >
> > > From: Peter Cipov
> > > Sent: Thursday, February 18, 2021 1:20 PM
> > > To: users@kafka.apache.org
> > > Subject: Abor
ruary 18, 2021 1:20 PM
> > To: users@kafka.apache.org
> > Subject: Abort transaction semantics
> >
> > Hello
> > I have a question regarding aborting transactions in kafka client 2.4.1.
> >
> > lets have following code :
> >
> > ... propper t
eter Cipov
> Sent: Thursday, February 18, 2021 1:20 PM
> To: users@kafka.apache.org
> Subject: Abort transaction semantics
>
> Hello
> I have a question regarding aborting transactions in kafka client 2.4.1.
>
> lets have following code :
>
> ... propper transaction producer
You have to perform seeks (using the consumer) to the lowest unprocessed offset
for each partition returned by the poll, before the next poll.
From: Peter Cipov
Sent: Thursday, February 18, 2021 1:20 PM
To: users@kafka.apache.org
Subject: Abort transaction
Hello
I have a question regarding aborting transactions in kafka client 2.4.1.
lets have following code :
... propper transaction producer consumer creation, consumer autocommit =
false
producer.transactionInit();
while(true) {
records = consumer.poll();
logRecordOffsets(records)
producer
