kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: KAFKA-5481: ListOffsetResponse isn't logged in the right way with trace level enabled
Date Fri, 21 Jul 2017 23:55:43 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk da42977a0 -> 6c6cf014f


KAFKA-5481: ListOffsetResponse isn't logged in the right way with trace level enabled

Added toString() method to ListOffsetResponse for logging

Author: ppatierno <ppatierno@live.com>
Author: Paolo Patierno <ppatierno@live.com>

Reviewers: Ewen Cheslack-Postava <ewen@confluent.io>

Closes #3383 from ppatierno/kafka-5481


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

Branch: refs/heads/trunk
Commit: 6c6cf014f6eb9c90453e6ac1b01b8c1851d98f06
Parents: da42977
Author: ppatierno <ppatierno@live.com>
Authored: Fri Jul 21 16:55:38 2017 -0700
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Fri Jul 21 16:55:38 2017 -0700

----------------------------------------------------------------------
 .../apache/kafka/common/requests/ListOffsetResponse.java  | 10 ++++++++++
 1 file changed, 10 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/6c6cf014/clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java
b/clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java
index 7dfaedc..8fe8ba7 100644
--- a/clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java
+++ b/clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java
@@ -191,4 +191,14 @@ public class ListOffsetResponse extends AbstractResponse {
 
         return struct;
     }
+
+    @Override
+    public String toString() {
+        StringBuilder bld = new StringBuilder();
+        bld.append("(type=ListOffsetResponse")
+            .append(", throttleTimeMs=").append(throttleTimeMs)
+            .append(", responseData=").append(responseData)
+            .append(")");
+        return bld.toString();
+    }
 }


Mime
View raw message