Mirror of Apache Kafka

kafkascala

You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

Tree: 1c7fdd2843

Branches Tags

${ item.name }

Create tag ${ searchTerm }

Create branch ${ searchTerm }

from '1c7fdd2843'

${ noResults }

src-kafka/clients/src

History

Apurva Mehta 8b04d8ba07 KAFKA-5269; Retry on unknown topic/partition error in transactional requests ... We should retry AddPartitionsToTxnRequest and TxnOffsetCommitRequest when receiving an UNKNOWN_TOPIC_OR_PARTITION error. As described in the JIRA: It turns out that the `UNKNOWN_TOPIC_OR_PARTITION` is returned from the request handler in KafkaAPis for the AddPartitionsToTxn and the TxnOffsetCommitRequest when the broker's metadata doesn't contain one or more partitions in the request. This can happen for instance when the broker is bounced and has not received the cluster metadata yet. We should retry in these cases, as this is the model followed by the consumer when committing offsets, and by the producer with a ProduceRequest. Author: Apurva Mehta <apurva@confluent.io> Reviewers: Guozhang Wang <wangguoz@gmail.com>, Jason Gustafson <jason@confluent.io> Closes #3094 from apurvam/KAFKA-5269-handle-unknown-topic-partition-in-transaction-manager		8 years ago
..
main/java/org/apache/kafka	KAFKA-5269; Retry on unknown topic/partition error in transactional requests	8 years ago
test	KAFKA-5269; Retry on unknown topic/partition error in transactional requests	8 years ago