[ https://issues.apache.org/jira/browse/KAFKA-14963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Luke Chen resolved KAFKA-14963. ------------------------------- Resolution: Fixed > Incorrect partition count metrics for kraft controllers > ------------------------------------------------------- > > Key: KAFKA-14963 > URL: https://issues.apache.org/jira/browse/KAFKA-14963 > Project: Kafka > Issue Type: Bug > Components: controller, kraft > Affects Versions: 3.4.0 > Reporter: José Armando García Sancio > Assignee: José Armando García Sancio > Priority: Major > Fix For: 3.4.1 > > > It is possible for the KRaft controller to report more partitions than are > available in the cluster. This is because the following test fail against > 3.4.0: > {code:java} > @Test > public void testPartitionCountDecreased() { > ControllerMetrics metrics = new MockControllerMetrics(); > ControllerMetricsManager manager = new > ControllerMetricsManager(metrics); Uuid createTopicId = > Uuid.randomUuid(); > Uuid createPartitionTopicId = new Uuid( > createTopicId.getMostSignificantBits(), > createTopicId.getLeastSignificantBits() > ); > Uuid removeTopicId = new > Uuid(createTopicId.getMostSignificantBits(), > createTopicId.getLeastSignificantBits()); > manager.replay(topicRecord("test", createTopicId)); > manager.replay(partitionRecord(createPartitionTopicId, 0, 0, > Arrays.asList(0, 1, 2))); > manager.replay(partitionRecord(createPartitionTopicId, 1, 0, > Arrays.asList(0, 1, 2))); > manager.replay(removeTopicRecord(removeTopicId)); > assertEquals(0, metrics.globalPartitionCount()); > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)