KAFKA-5481: ListOffsetResponse isn't logged in the right way with tra…

…ce level enabled Added toString() method to ListOffsetResponse for logging Author: ppatierno <[email protected]> Author: Paolo Patierno <[email protected]> Reviewers: Ewen Cheslack-Postava <[email protected]> Closes apache#3383 from ppatierno/kafka-5481
szhang1 · Jul 21, 2017 · 6c6cf01 · 6c6cf01
1 parent da42977
commit 6c6cf01
Showing 1 changed file with 10 additions and 0 deletions.
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
@@ -191,4 +191,14 @@ protected Struct toStruct(short version) {
 
         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();
+    }
 }