kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: Allow Serdes subclasses to access WrapperSerde
Date Fri, 13 May 2016 22:32:27 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 1c4b943f2 -> 08205de18


MINOR: Allow Serdes subclasses to access WrapperSerde

This PR loosens access restrictions on `WrapperSerde` to `protected` so that users can define
a `Serdes` subclass that provides additional custom serde members following the same pattern
as the parent class.

This is my own work and is compatible with Kafka's license.

Author: Jeff Klukas <jeff@klukas.net>

Reviewers: Guozhang Wang

Closes #1382 from jklukas/expose-wrapperserde


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/08205de1
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/08205de1
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/08205de1

Branch: refs/heads/trunk
Commit: 08205de185090b0cd744844b58b1508c82459d28
Parents: 1c4b943
Author: Jeff Klukas <jeff@klukas.net>
Authored: Fri May 13 15:32:24 2016 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Fri May 13 15:32:24 2016 -0700

----------------------------------------------------------------------
 .../main/java/org/apache/kafka/common/serialization/Serdes.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/08205de1/clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java b/clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java
index 9075a93..e5fb6c0 100644
--- a/clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java
+++ b/clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java
@@ -23,7 +23,7 @@ import java.util.Map;
  */
 public class Serdes {
 
-    static private class WrapperSerde<T> implements Serde<T> {
+    static protected class WrapperSerde<T> implements Serde<T> {
         final private Serializer<T> serializer;
         final private Deserializer<T> deserializer;
 


Mime
View raw message