You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2016/05/13 22:32:27 UTC
kafka git commit: MINOR: Allow Serdes subclasses to access
WrapperSerde
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 <je...@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 <je...@klukas.net>
Authored: Fri May 13 15:32:24 2016 -0700
Committer: Guozhang Wang <wa...@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;