José Armando García Sancio created KAFKA-14963:
--------------------------------------------------
Summary: 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
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)
