tree 26062a64e56b714775add7e258146bab7ed46fe0
parent ff77b3ad041c1a4c80119f960e1f87c07b9e93dd
author Danica Fine <danica.fine@gmail.com> 1686166511 +0200
committer GitHub <noreply@github.com> 1686166511 -0400
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJkgNvvCRBK7hj4Ov3rIwAAGicIAEezhOIxKSuNx2K8BeQfZ5QA
 SyKaZCrtnooZ6ZFLz22vd8uQCb46bJEfiyeYf+0qdzhKvAbdztv3BuVVq51jIDah
 x6IqRPTVR/dKruQCKkZ2tJOvUz5vWEQG0fG/1uuc+vg/n8Q5b2VUUiE6EZa67ae5
 /0SHL2hdxdqh2He95qHCAK9XHZvX1BE5079JFGRCvkl1hCiaNRNISyt8e/pbk5Br
 Mrm/yLndXBFirDTB8ifdXfThFPBfsbp+LbK6XP6Qk6FojlZmNmitGTlznFK0XyBF
 klNbrhF2ppD71tVkKmIBKXaREbRmKvji1mvLtbQXwt98M3Hplz6fuoKvNkRkoaE=
 =6oZL
 -----END PGP SIGNATURE-----
 

KAFKA-14539: Simplify StreamsMetadataState by replacing the Cluster metadata with partition info map (#13751)

Replace usage of Cluster in StreamsMetadataState with Map<String, List>. Update StreamsPartitionAssignor#onAssignment method to pass existing Map<TopicPartition, PartitionInfo> instead of fake Cluster object.

Behavior remains the same; updated existing unit tests accordingly.

Reviewers:  Walker Carlson <wcarlson@confluent.io>, Bill Bejeck <bbejeck@apache.org>