jolshan commented on a change in pull request #9473:
URL: https://github.com/apache/kafka/pull/9473#discussion_r512069339
##########
File path: core/src/main/scala/kafka/zk/KafkaZkClient.scala
##########
@@ -616,7 +683,7 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient, isSecure: Boo
getDataResponses.flatMap { getDataResponse =>
val topic = getDataResponse.ctx.get.asInstanceOf[String]
if (getDataResponse.resultCode == Code.OK) {
- val partitionMap = TopicZNode.decode(topic, getDataResponse.data).map
{ case (k, v) => (k.partition, v) }
+ val partitionMap = TopicZNode.decode(topic,
getDataResponse.data).assignment.map { case (k, v) => (k.partition, v) }
Review comment:
I've found a few style errors while working on this and I wasn't sure
the protocol. I guess it makes sense to fix the style in the block of code I'm
working on. (But it's a little confusing when its not the areas of code I'm
working on)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
