You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jj...@apache.org on 2016/10/19 23:34:46 UTC
kafka git commit: KAFKA-4250;
Make ProducerRecord and ConsumerRecord extensible
Repository: kafka
Updated Branches:
refs/heads/trunk b51002c57 -> 46666a1f6
KAFKA-4250; Make ProducerRecord and ConsumerRecord extensible
Signed-off-by: radai-rosenblatt <radai.rosenblattgmail.com>
Author: radai-rosenblatt <ra...@gmail.com>
Reviewers: Joel Koshy <jj...@gmail.com>
Closes #1961 from radai-rosenblatt/extensibility
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/46666a1f
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/46666a1f
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/46666a1f
Branch: refs/heads/trunk
Commit: 46666a1f64af3617d7f47f50fedf3b9a6ae5cddb
Parents: b51002c
Author: radai-rosenblatt <ra...@gmail.com>
Authored: Wed Oct 19 16:34:29 2016 -0700
Committer: Joel Koshy <jj...@gmail.com>
Committed: Wed Oct 19 16:34:29 2016 -0700
----------------------------------------------------------------------
.../java/org/apache/kafka/clients/consumer/ConsumerRecord.java | 2 +-
.../java/org/apache/kafka/clients/producer/ProducerRecord.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/46666a1f/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java b/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java
index 586156e..c8aef53 100644
--- a/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java
+++ b/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java
@@ -19,7 +19,7 @@ import org.apache.kafka.common.record.TimestampType;
* A key/value pair to be received from Kafka. This consists of a topic name and a partition number, from which the
* record is being received and an offset that points to the record in a Kafka partition.
*/
-public final class ConsumerRecord<K, V> {
+public class ConsumerRecord<K, V> {
public static final long NO_TIMESTAMP = Record.NO_TIMESTAMP;
public static final int NULL_SIZE = -1;
public static final int NULL_CHECKSUM = -1;
http://git-wip-us.apache.org/repos/asf/kafka/blob/46666a1f/clients/src/main/java/org/apache/kafka/clients/producer/ProducerRecord.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/producer/ProducerRecord.java b/clients/src/main/java/org/apache/kafka/clients/producer/ProducerRecord.java
index 536067e..86112f1 100644
--- a/clients/src/main/java/org/apache/kafka/clients/producer/ProducerRecord.java
+++ b/clients/src/main/java/org/apache/kafka/clients/producer/ProducerRecord.java
@@ -36,7 +36,7 @@ package org.apache.kafka.clients.producer;
* In either of the cases above, the timestamp that has actually been used will be returned to user in
* {@link RecordMetadata}
*/
-public final class ProducerRecord<K, V> {
+public class ProducerRecord<K, V> {
private final String topic;
private final Integer partition;