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 <[email protected]>
AuthorDate: Fri Aug 27 11:11:57 2021 +0200
MINOR: Update `TransactionalMessageCopier` to use the latest transaction
pattern (#11265)
Reviewers: Jason Gustafson <[email protected]>
---
.../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) {
