[kafka] branch trunk updated: MINOR: Fix Partition::toString method (#6971)

[jg...@apache.org]

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

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


The following commit(s) were added to refs/heads/trunk by this push:
     new d40805d  MINOR: Fix Partition::toString method (#6971)
d40805d is described below

commit d40805deacc5416be89984550b82c0b5d9dd57c5
Author: Vikas Singh <50...@users.noreply.github.com>
AuthorDate: Thu Jun 20 09:49:32 2019 -0700

    MINOR: Fix Partition::toString method (#6971)
    
    The AllReplicas was only printing remote replica ids. This change prints
    all ids, including local one.
    
    Reviewers: José Armando García Sancio <js...@users.noreply.github.com>, Jason Gustafson <ja...@confluent.io>
---
 core/src/main/scala/kafka/cluster/Partition.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/main/scala/kafka/cluster/Partition.scala b/core/src/main/scala/kafka/cluster/Partition.scala
index 544fc0c..0574cae 100755
--- a/core/src/main/scala/kafka/cluster/Partition.scala
+++ b/core/src/main/scala/kafka/cluster/Partition.scala
@@ -1201,7 +1201,7 @@ class Partition(val topicPartition: TopicPartition,
     partitionString.append("Topic: " + topic)
     partitionString.append("; Partition: " + partitionId)
     partitionString.append("; Leader: " + leaderReplicaIdOpt)
-    partitionString.append("; AllReplicas: " + remoteReplicasMap.keys.mkString(","))
+    partitionString.append("; AllReplicas: " + allReplicaIds.mkString(","))
     partitionString.append("; InSyncReplicas: " + inSyncReplicas.mkString(","))
     partitionString.toString
   }