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 <[email protected]>
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 <[email protected]>,
Jason Gustafson <[email protected]>
---
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
}
