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 2017/09/08 21:13:15 UTC
kafka git commit: MINOR: make Consumed copy ctor protected
Repository: kafka
Updated Branches:
refs/heads/trunk 9cec4109b -> 689a84c7d
MINOR: make Consumed copy ctor protected
Author: Damian Guy <da...@gmail.com>
Reviewers: Bill Bejeck <bi...@confluent.io>, Matthias J. Sax <ma...@confluent.io>, Guozhang Wang <wa...@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 <da...@gmail.com>
Authored: Fri Sep 8 14:13:11 2017 -0700
Committer: Guozhang Wang <wa...@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);
}