KAFKA-3641; Fix RecordMetadata constructor backward compatibility
Author: Grant Henke <granthenke@gmail.com>
Reviewers: Gwen Shapira, Ismael Juma
Closes #1292 from granthenke/recordmeta-compat
diff --git a/clients/src/main/java/org/apache/kafka/clients/producer/RecordMetadata.java b/clients/src/main/java/org/apache/kafka/clients/producer/RecordMetadata.java
index 988da16..00a4374 100644
--- a/clients/src/main/java/org/apache/kafka/clients/producer/RecordMetadata.java
+++ b/clients/src/main/java/org/apache/kafka/clients/producer/RecordMetadata.java
@@ -17,6 +17,7 @@
package org.apache.kafka.clients.producer;
import org.apache.kafka.common.TopicPartition;
+import org.apache.kafka.common.record.Record;
/**
* The metadata for a record that has been acknowledged by the server
@@ -51,6 +52,11 @@
this.topicPartition = topicPartition;
}
+ @Deprecated
+ public RecordMetadata(TopicPartition topicPartition, long baseOffset, long relativeOffset) {
+ this(topicPartition, baseOffset, relativeOffset, Record.NO_TIMESTAMP, -1, -1, -1);
+ }
+
public RecordMetadata(TopicPartition topicPartition, long baseOffset, long relativeOffset,
long timestamp, long checksum, int serializedKeySize, int serializedValueSize) {
// ignore the relativeOffset if the base offset is -1,