kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Saher Ahwal <saher.ah...@gmail.com>
Subject Kafka Exactly-Once Semantics in .NET support
Date Tue, 30 Jun 2020 22:22:25 GMT

I am working on exactly-once semantics with Kafka and I have streaming
scenario of read-process-write. I noticed the new exactly-once scalability
design with correctness in case of partition reassignment here:

It all looks great and I understand we need to rely on
PendingTransatcionException and ProducerFencedException. However, we are
using confluent library and .NET and I don't see any of these exceptions.

How do I ensure correctness of fencing of zombie producer transactions when
using .NET confluent library? What exceptions are retry-able and what are
not? Can I call abortTransaction on any Kafka exception ? I don't find good
examples in the documentation.
Any pointers or answers are kindly appreciated.

Thanks in advance

*Saher Ahwal*

*Massachusetts Institute of Technology '13, '14*
*Department of Electrical Engineering and Computer Science*
*saher@alum.mit.edu <saher@mit.edu> | 617 680 4877*

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message