You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by js...@apache.org on 2022/12/06 21:01:50 UTC

[kafka] branch trunk updated (5aad085a8e7 -> e96e42ead4b)

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