kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: MINOR: Add toString implementations to Subscription and Assignment
Date Mon, 09 May 2016 22:34:37 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 4331bf4ff -> ff8580da6


MINOR: Add toString implementations to Subscription and Assignment

Author: Jason Gustafson <jason@confluent.io>

Reviewers: Ismael Juma <ismael@juma.me.uk>

Closes #1354 from hachikuji/minor-add-missing-assignor-tostrings


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

Branch: refs/heads/trunk
Commit: ff8580da6fb1d65b206df544ebd574222abe7f3f
Parents: 4331bf4
Author: Jason Gustafson <jason@confluent.io>
Authored: Mon May 9 23:34:30 2016 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Mon May 9 23:34:30 2016 +0100

----------------------------------------------------------------------
 .../clients/consumer/internals/PartitionAssignor.java   | 12 ++++++++++++
 1 file changed, 12 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/ff8580da/clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignor.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignor.java
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignor.java
index df8f2f1..02eddd1 100644
--- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignor.java
+++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignor.java
@@ -89,6 +89,12 @@ public interface PartitionAssignor {
             return userData;
         }
 
+        @Override
+        public String toString() {
+            return "Subscription(" +
+                    "topics=" + topics +
+                    ')';
+        }
     }
 
     class Assignment {
@@ -112,6 +118,12 @@ public interface PartitionAssignor {
             return userData;
         }
 
+        @Override
+        public String toString() {
+            return "Assignment(" +
+                    "partitions=" + partitions +
+                    ')';
+        }
     }
 
 }


Mime
View raw message