KAFKA-3641; Fix RecordMetadata constructor backward compatibility Author: Grant Henke <[email protected]>
Reviewers: Gwen Shapira, Ismael Juma Closes #1292 from granthenke/recordmeta-compat Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/096b8b84 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/096b8b84 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/096b8b84 Branch: refs/heads/0.10.0 Commit: 096b8b84e0dba8cdf0e0f7afae8d118a68e06e6c Parents: 3414d56 Author: Grant Henke <[email protected]> Authored: Fri Apr 29 14:48:25 2016 -0700 Committer: Gwen Shapira <[email protected]> Committed: Fri Apr 29 14:48:25 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/kafka/clients/producer/RecordMetadata.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/096b8b84/clients/src/main/java/org/apache/kafka/clients/producer/RecordMetadata.java ---------------------------------------------------------------------- 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 @@ public final class RecordMetadata { 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,
