Can't update MSK config due to number of partitions

0

When I try to update MSK cluster config to the latest version I get an error

The number of partitions per broker is above the recommended limit. Add more brokers and rearrange the partitions per broker to be below the recommended limit, then retry the request

However, according to https://docs.aws.amazon.com/msk/latest/developerguide/bestpractices.html kafka.m5.large should work up to 1000 partitions per broker.

Looking at Kafka connect for the cluster the three brokers have 560, 554 and 524 each.

Is there a way to force the MSK cluster config to update?

asked 7 months ago1357 views
3 Answers
0

Hi!

As you are way below the recommended partition level I would recommend to open a support ticket to see whether they help.

Bests!

profile pictureAWS
answered 7 months ago
0

Please make sure you are counting all partitions (with their replicas), not only partition leaders. It is very possible that the numbers you are presenting are leaders only per broker, and a total number would be about as 3 times per broker, which does exceed the limit. If that is not the case, go ahead and open AWS Support ticket.

AWS
EdbE
answered 7 months ago
0

Since you are using kafka.m5.large instance type for your brokers, the maximum recommended number of partitions per broker is 1000. Thus, I would request you to check the partition count at broker level. You can check it in the Kafka CloudWatch metrics (ClusterName, brokerId)with metric PartitionCount. This will show you the exact number of partitions on each of your broker including the replica and leader brokers. If you are reaching the maximum limit of 1000 for any of your broker, the exception that you are getting is expected.

So, if the partition count is exceeding, you would need to take any of the below actions to reduce the partition count per broker.

  1. Increase the number of brokers within the cluster and then reassign partitions to reduce the number of partitions per broker

  2. Decrease the number of partitions by deleting unused topics

  3. Modify instance type to higher instance type. For example kafka.m5.2xlarge(if possible) since it has a recommended upper limit of 2000 partitions per broker.

With that being said, I would request you to follow any of the above steps to make sure the partition count is within the limit[1] according to your broker type. After doing that, try to change the configuration you required.

However, if you are not exceeding the partition count 1000 on all your brokers and still you are not able to update the Configuration, I would request you to reach out to us over a Support Case.

AWS
SUPPORT ENGINEER
answered 7 months ago

You are not logged in. Log in to post an answer.

A good answer clearly answers the question and provides constructive feedback and encourages professional growth in the question asker.

Guidelines for Answering Questions