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)
