[
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)
