[kafka] branch 0.10.2 updated: KAFKA-6371; Fix DelayedFetch toString (#4328)

[jg...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jgus pushed a commit to branch 0.10.2
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/0.10.2 by this push:
     new d72a00b  KAFKA-6371; Fix DelayedFetch toString (#4328)
d72a00b is described below

commit d72a00b1d6dcae422e4663b860b23533ce866a5a
Author: Maytee Chinavanichkit <ma...@gmail.com>
AuthorDate: Sun Feb 25 06:31:51 2018 +0900

    KAFKA-6371; Fix DelayedFetch toString (#4328)
    
    Reviewers: Ismael Juma <is...@juma.me.uk>, Jason Gustafson <ja...@confluent.io>
---
 core/src/main/scala/kafka/server/DelayedFetch.scala | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/core/src/main/scala/kafka/server/DelayedFetch.scala b/core/src/main/scala/kafka/server/DelayedFetch.scala
index a05131a..ae3cf46 100644
--- a/core/src/main/scala/kafka/server/DelayedFetch.scala
+++ b/core/src/main/scala/kafka/server/DelayedFetch.scala
@@ -44,10 +44,8 @@ case class FetchMetadata(fetchMinBytes: Int,
                          replicaId: Int,
                          fetchPartitionStatus: Seq[(TopicPartition, FetchPartitionStatus)]) {
 
-  override def toString = "[minBytes: " + fetchMinBytes + ", " +
-                          "onlyLeader:" + fetchOnlyLeader + ", "
-                          "onlyCommitted: " + fetchOnlyCommitted + ", "
-                          "partitionStatus: " + fetchPartitionStatus + "]"
+  override def toString = s"[minBytes: $fetchMinBytes, onlyLeader: $fetchOnlyLeader, " +
+                          s"onlyCommitted: $fetchOnlyCommitted, partitionStatus: $fetchPartitionStatus]"
 }
 /**
  * A delayed fetch operation that can be created by the replica manager and watched

-- 
To stop receiving notification emails like this one, please contact
jgus@apache.org.