You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "wenxuanguan (JIRA)" <ji...@apache.org> on 2019/05/30 08:17:00 UTC
[jira] [Commented] (KAFKA-4815) Idempotent/transactional Producer
(KIP-98)
[ 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)