Re: Transactions and `endOffsets` Java client consumer method

2022-03-21 Thread Chris Jansen
Hi Guozhang, Thanks for getting back to me. I'm using Confluent's distribution version 6.2.2, so Kafka 2.8.1. Could there be some consumer or broker configuration I'm missing that would change this behaviour? Just to confirm, here are my consumer settings: auto.offset.reset -> earliest, isolatio

Re: Transactions and `endOffsets` Java client consumer method

2022-03-21 Thread Chris Jansen
So an update on this, it seems that the consumer reports an unreadable end of the log if the transaction has been aborted. Is this the intended behaviour? Thanks again, Chris On Mon, Mar 21, 2022 at 12:25 PM Chris Jansen wrote: > Hi Guozhang, > > Thanks for getting back to me. I'm using Conflu

Re: Transactions and `endOffsets` Java client consumer method

2022-03-21 Thread Guozhang Wang
Hi Chris, What do you mean by "an unreadable end of the log"? Could you elaborate? The version you used is recent enough, and the configs seems okay. So I think there are some issues elsewhere. On Mon, Mar 21, 2022 at 5:51 AM Chris Jansen wrote: > So an update on this, it seems that the consum