[
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)
