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: make Consumed copy ctor protected
Date Fri, 08 Sep 2017 21:13:15 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 9cec4109b -> 689a84c7d


MINOR: make Consumed copy ctor protected

Author: Damian Guy <damian.guy@gmail.com>

Reviewers: Bill Bejeck <bill@confluent.io>, Matthias J. Sax <matthias@confluent.io>,
Guozhang Wang <wangguoz@gmail.com>

Closes #3816 from dguy/consumed-ctor


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

Branch: refs/heads/trunk
Commit: 689a84c7d6aec32956aabf2e8b3612e754ba2e88
Parents: 9cec410
Author: Damian Guy <damian.guy@gmail.com>
Authored: Fri Sep 8 14:13:11 2017 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Fri Sep 8 14:13:11 2017 -0700

----------------------------------------------------------------------
 streams/src/main/java/org/apache/kafka/streams/Consumed.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/689a84c7/streams/src/main/java/org/apache/kafka/streams/Consumed.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/Consumed.java b/streams/src/main/java/org/apache/kafka/streams/Consumed.java
index fb42b99..4a936e1 100644
--- a/streams/src/main/java/org/apache/kafka/streams/Consumed.java
+++ b/streams/src/main/java/org/apache/kafka/streams/Consumed.java
@@ -51,7 +51,7 @@ public class Consumed<K, V> {
      * Create an instance of {@link Consumed} from an existing instance.
      * @param consumed  the instance of {@link Consumed} to copy
      */
-    public Consumed(final Consumed<K, V> consumed) {
+    protected Consumed(final Consumed<K, V> consumed) {
         this(consumed.keySerde, consumed.valueSerde, consumed.timestampExtractor, consumed.resetPolicy);
     }
 


Mime
View raw message