You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2016/05/09 22:34:37 UTC
kafka git commit: MINOR: Add toString implementations to Subscription
and Assignment
Repository: kafka
Updated Branches:
refs/heads/trunk 4331bf4ff -> ff8580da6
MINOR: Add toString implementations to Subscription and Assignment
Author: Jason Gustafson <ja...@confluent.io>
Reviewers: Ismael Juma <is...@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 <ja...@confluent.io>
Authored: Mon May 9 23:34:30 2016 +0100
Committer: Ismael Juma <is...@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 +
+ ')';
+ }
}
}