Re: Offsets: consumption and production in rollback

2023-06-29 Thread Andrew Schofield
: miércoles, 28 de junio de 2023 14:54 > Para: dev@kafka.apache.org > Asunto: Re: Offsets: consumption and production in rollback > > Hi Henry, > Consumers get to choose an isolation level. There’s one instance I can think > of where AdminClient also has > some ability to

RE: Offsets: consumption and production in rollback

2023-06-29 Thread Henry GALVEZ
ot a one-to-one relationship > between offsets and consumable records. > > Hope this helps, > Andrew > > Begin forwarded message: > > From: Henry GALVEZ > Subject: Offsets: consumption and production in rollback > Date: 27 June 2023 at 10:48:31 BST > To: "us...@kafka.ap

Re: Offsets: consumption and production in rollback

2023-06-28 Thread Andrew Schofield
> > > De: Andrew Schofield > Enviado: martes, 27 de junio de 2023 13:22 > Para: dev@kafka.apache.org > Asunto: Fwd: Offsets: consumption and production in rollback > > Hi Henry, > Thanks for your message. > > Kafka transactions ar

RE: Offsets: consumption and production in rollback

2023-06-28 Thread Henry GALVEZ
m not sure that this is really “bogus lag” but, when you’re using transactions, there’s not a one-to-one relationship between offsets and consumable records. Hope this helps, Andrew Begin forwarded message: From: Henry GALVEZ Subject: Offsets: consumption and production in rollback Date: 27 June 2023 at 10

Fwd: Offsets: consumption and production in rollback

2023-06-27 Thread Andrew Schofield
lag” but, when you’re using transactions, there’s not a one-to-one relationship between offsets and consumable records. Hope this helps, Andrew Begin forwarded message: From: Henry GALVEZ Subject: Offsets: consumption and production in rollback Date: 27 June 2023 at 10:48:31 BST To: &qu

Offsets: consumption and production in rollback

2023-06-27 Thread Henry GALVEZ
I have some doubts regarding message consumption and production, as well as transactional capabilities. I am using a Kafka template to produce a message within a transaction. After that, I execute another transaction that produces a message and intentionally throws a runtime exception to