You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gw...@apache.org on 2016/04/29 23:48:33 UTC
kafka git commit: KAFKA-3641;
Fix RecordMetadata constructor backward compatibility
Repository: kafka
Updated Branches:
refs/heads/trunk 3414d5612 -> 096b8b84e
KAFKA-3641; Fix RecordMetadata constructor backward compatibility
Author: Grant Henke <gr...@gmail.com>
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/trunk
Commit: 096b8b84e0dba8cdf0e0f7afae8d118a68e06e6c
Parents: 3414d56
Author: Grant Henke <gr...@gmail.com>
Authored: Fri Apr 29 14:48:25 2016 -0700
Committer: Gwen Shapira <cs...@gmail.com>
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,