jolshan commented on PR #16229:
URL: https://github.com/apache/kafka/pull/16229#issuecomment-2159278838
> producer.beginTransaction()
try {
producer.send(record).get()
fail("expected ProducerFencedException") // <- test failed here
Interesting. I thought it would fence immediately but we might see some
extra concurrent transaction errors. I'm curious if we could commit such a
transaction in this state, but maybe this is good enough.
The only other thing I could think of is will a long blocking call be an
issue for users of this api. Curious about @C0urante since I believe he was the
one who implemented this for connect.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
