You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2021/08/27 09:13:29 UTC
[kafka] branch trunk updated: MINOR: Update
`TransactionalMessageCopier` to use the latest transaction pattern (#11265)
This is an automated email from the ASF dual-hosted git repository.
dajac pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 4e2f2b0 MINOR: Update `TransactionalMessageCopier` to use the latest transaction pattern (#11265)
4e2f2b0 is described below
commit 4e2f2b0674848ea105e74e787403b0260f91dc1e
Author: David Jacot <dj...@confluent.io>
AuthorDate: Fri Aug 27 11:11:57 2021 +0200
MINOR: Update `TransactionalMessageCopier` to use the latest transaction pattern (#11265)
Reviewers: Jason Gustafson <ja...@confluent.io>
---
.../main/java/org/apache/kafka/tools/TransactionalMessageCopier.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java b/tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java
index 3e0e3a3..fba750a 100644
--- a/tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java
+++ b/tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java
@@ -33,7 +33,6 @@ import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.KafkaException;
import org.apache.kafka.common.TopicPartition;
-import org.apache.kafka.common.errors.OutOfOrderSequenceException;
import org.apache.kafka.common.errors.ProducerFencedException;
import org.apache.kafka.common.errors.WakeupException;
import org.apache.kafka.common.utils.Exit;
@@ -361,7 +360,7 @@ public class TransactionalMessageCopier {
numMessagesProcessedSinceLastRebalance.getAndAdd(messagesSentWithinCurrentTxn);
totalMessageProcessed.getAndAdd(messagesSentWithinCurrentTxn);
}
- } catch (ProducerFencedException | OutOfOrderSequenceException e) {
+ } catch (ProducerFencedException e) {
// We cannot recover from these errors, so just rethrow them and let the process fail
throw e;
} catch (KafkaException e) {