This is an automated email from the ASF dual-hosted git repository.
jsancio pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 5aad085a8e7 KAFKA-14417: Producer doesn't handle REQUEST_TIMED_OUT for
InitProducerIdRequest, treats as fatal error (#12915)
add e96e42ead4b KAFKA-14386; Return TopicAssignment from the ReplicaPlacer
(#12892)
No new revisions were added by this update.
Summary of changes:
.../controller/ReplicationControlManager.java | 31 ++++-----
.../placement/PartitionAssignment.java} | 48 +++++++-------
.../kafka/metadata/placement/ReplicaPlacer.java | 6 +-
.../metadata/placement/StripedReplicaPlacer.java | 7 ++-
.../TopicAssignment.java} | 41 ++++++------
.../controller/ClusterControlManagerTest.java | 17 ++---
.../placement/PartitionAssignmentTest.java | 60 ++++++++++++++++++
.../placement/StripedReplicaPlacerTest.java | 33 ++++------
.../metadata/placement/TopicAssignmentTest.java | 73 ++++++++++++++++++++++
9 files changed, 222 insertions(+), 94 deletions(-)
copy
metadata/src/main/java/org/apache/kafka/{controller/BrokerControlStates.java =>
metadata/placement/PartitionAssignment.java} (50%)
copy
metadata/src/main/java/org/apache/kafka/metadata/{BrokerRegistrationReply.java
=> placement/TopicAssignment.java} (51%)
create mode 100644
metadata/src/test/java/org/apache/kafka/metadata/placement/PartitionAssignmentTest.java
create mode 100644
metadata/src/test/java/org/apache/kafka/metadata/placement/TopicAssignmentTest.java
