This is an automated email from the ASF dual-hosted git repository.
junrao pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 7719b5f70dd KAFKA-18644: improve generic type names for internal
FK-join classes (#18700)
add ad031b99d31 KAFKA-18635: reenable the unclean shutdown detection
(#18277)
No new revisions were added by this update.
Summary of changes:
.../EligibleLeaderReplicasIntegrationTest.java | 446 +++++++++++++++++++++
.../kafka/controller/ClusterControlManager.java | 31 +-
.../apache/kafka/controller/QuorumController.java | 9 +-
.../controller/ReplicationControlManager.java | 15 +-
.../controller/ClusterControlManagerTest.java | 118 ++++--
.../controller/ProducerIdControlManagerTest.java | 2 +-
.../kafka/controller/QuorumControllerTest.java | 19 +-
.../controller/ReplicationControlManagerTest.java | 42 +-
8 files changed, 613 insertions(+), 69 deletions(-)
create mode 100644
core/src/test/java/kafka/server/integration/EligibleLeaderReplicasIntegrationTest.java
