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)