[ https://issues.apache.org/jira/browse/KAFKA-4815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16851627#comment-16851627 ]
wenxuanguan commented on KAFKA-4815: ------------------------------------ how transaction support multiple producer instances. when multiple producer share the same txn id, throw the following exception: org.apache.kafka.common.KafkaException: Cannot execute transactional method because we are in an error state at org.apache.kafka.clients.producer.internals.TransactionManager.maybeFailWithError(TransactionManager.java:784) at org.apache.kafka.clients.producer.internals.TransactionManager.beginTransaction(TransactionManager.java:215) at org.apache.kafka.clients.producer.KafkaProducer.beginTransaction(KafkaProducer.java:606) at com.matt.test.kafka.producer.ProducerTransactionExample.main(ProducerTransactionExample.java:68) Caused by: org.apache.kafka.common.errors.ProducerFencedException: Producer attempted an operation with an old epoch. Either there is a newer producer with the same transactionalId, or the producer's transaction has been expired by the broker. > Idempotent/transactional Producer (KIP-98) > ------------------------------------------ > > Key: KAFKA-4815 > URL: https://issues.apache.org/jira/browse/KAFKA-4815 > Project: Kafka > Issue Type: New Feature > Components: clients, core, producer > Reporter: Jason Gustafson > Assignee: Jason Gustafson > Priority: Major > Labels: kip > Fix For: 0.11.0.0 > > > This issue tracks implementation progress for KIP-98: > https://cwiki.apache.org/confluence/display/KAFKA/KIP-98+-+Exactly+Once+Delivery+and+Transactional+Messaging. -- This message was sent by Atlassian JIRA (v7.6.3#76005)