wcarlson5 commented on code in PR #13751:
URL: https://github.com/apache/kafka/pull/13751#discussion_r1221950345
##########
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java:
##########
@@ -308,12 +308,17 @@ public synchronized <K> KeyQueryMetadata
getKeyQueryMetadataForKey(final String
*
* @param activePartitionHostMap the current mapping of {@link HostInfo}
-> {@link TopicPartition}s for active partitions
* @param standbyPartitionHostMap the current mapping of {@link HostInfo}
-> {@link TopicPartition}s for standby partitions
- * @param clusterMetadata the current clusterMetadata {@link
Cluster}
+ * @param topicPartitionInfo the current mapping of {@link
TopicPartition} -> {@Link PartitionInfo}
*/
synchronized void onChange(final Map<HostInfo, Set<TopicPartition>>
activePartitionHostMap,
final Map<HostInfo, Set<TopicPartition>>
standbyPartitionHostMap,
- final Cluster clusterMetadata) {
- this.clusterMetadata = clusterMetadata;
+ final Map<TopicPartition, PartitionInfo>
topicPartitionInfo) {
+ this.partitionsByTopic = new HashMap<>();
+ topicPartitionInfo.entrySet().forEach(entry -> this.partitionsByTopic
Review Comment:
Can we format this so it is a bit easier to read?
--
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.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
