You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Edoardo Comar (Jira)" <ji...@apache.org> on 2023/01/27 17:13:00 UTC

[jira] [Created] (KAFKA-14657) Admin.fenceProducers fails when Producer has ongoing transaction - but Producer gets fenced

Edoardo Comar created KAFKA-14657:
-------------------------------------

             Summary: Admin.fenceProducers fails when Producer has ongoing transaction - but Producer gets fenced
                 Key: KAFKA-14657
                 URL: https://issues.apache.org/jira/browse/KAFKA-14657
             Project: Kafka
          Issue Type: Bug
          Components: admin
            Reporter: Edoardo Comar
         Attachments: FenceProducerDuringTx.java, FenceProducerOutsideTx.java

{{Admin.fenceProducers() }}
fails with a ConcurrentTransactionsException if invoked when a Producer has a transaction ongoing.
However, further attempts by that producer to produce fail with InvalidProducerEpochException and the producer is not re-usable, 
cannot abort/commit as it is fenced.

Conversely, if 
{{Admin.fenceProducers() }}
is invoked while there is no open transaction, the call succeeds and further attempts by that producer to produce fail with ProducerFenced.

see attached snippets 

As the caller of {{Admin.fenceProducers() }} the call should succeed regardless of the state of the producer



--
This message was sent by Atlassian Jira
(v8.20.10#820010)