From 7ab70a562df5b971d129434bbf0c57c699507a6a Mon Sep 17 00:00:00 2001 From: Grant Henke Date: Fri, 29 Apr 2016 13:31:41 -0500 Subject: [PATCH] KAFKA-3641: Fix RecordMetadata constructor backward compatibility --- .../org/apache/kafka/clients/producer/RecordMetadata.java | 6 ++++++ 1 file changed, 6 insertions(+) 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,