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 988da16addf97..00a4374ef5543 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 @@ private RecordMetadata(TopicPartition topicPartition, long offset, long timestam 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,