[ https://issues.apache.org/jira/browse/KAFKA-6838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16478049#comment-16478049 ]
Felix Dsouza commented on KAFKA-6838: ------------------------------------- Thanks Mathias. Yeah, looks like it’s the same issue . Should I close this one as a duplicate ? > Transaction timeout after punctuation results in ProducerFencedException > ------------------------------------------------------------------------ > > Key: KAFKA-6838 > URL: https://issues.apache.org/jira/browse/KAFKA-6838 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 1.1.0 > Reporter: Felix Dsouza > Priority: Major > Attachments: punctuat-producer-fencing-borker.log > > > It looks like the EOS/transaction handling for stream punctuation does not > work correctly. > We have encountered ProducerFencedException in a specific case where new > events do not arrive before the transaction started by punctuation times out. > Following squence of events trigger this scenario. > 1. Punctuation is triggered, we delete some records from the State store > (logging enabled) . A transaction is registered on the broker. > txnState=Ongoing > 2. There are no new events to be consumed (period of inactivity) and no new > punctuation happening. > 3. Broker aborts the transaction after about 60000 ms (default transaction > timeout duration for the stream) , txnState=Ongoing -> txnState=PrepareAbort > -> txnState=CompleteAbort > 4. A new event comes in and hits producer fenced exception > > Attached are the logs from the broker where a successful processing, along > with transaction timeout and producer fencing is shown. > > -- This message was sent by Atlassian JIRA (v7.6.3#76005)