Alteração de quantidade de partições

Método 1: usar o console

1. Faça logon no console de gerenciamento.
2. Clique em no canto superior esquerdo para selecionar uma região.
   

   Selecione a região onde sua instância do Kafka está localizada.

3. Clique em e escolha Middleware > Distributed Message Service (for Kafka) para abrir o console do DMS for Kafka.
4. Clique na instância do Kafka desejada para exibir os detalhes da instância.
5. No painel de navegação, escolha Topics.
6. Modifique o número de partições usando um dos seguintes métodos:
   • Selecione um ou mais tópicos e clique em Edit Topic no canto superior esquerdo.
   • Na linha que contém o tópico desejado, clique em Edit.

7. Na caixa de diálogo Edit Topic, digite o número de partições e clique em OK.
   

   • O número de partições só pode ser aumentado.
   • Para garantir o desempenho, o console de Kafka permite um máximo de 200 partições para cada tópico.
   • O número total de partições de todos os tópicos não pode exceder o número máximo de partições permitidas pela instância.

Método 2: usar o Kafka Manager

1. Faça logon no Kafka Manager.
2. Escolha Topic > List para exibir a lista de tópicos.
3. Clique em um tópico para exibir seus detalhes.
4. Clique em Add Partitions.
   Figura 1 Página de detalhes do tópico
   

5. Digite o número de partições e clique em Add Partitions.
   Figura 2 Adicionar partições
   

   Se "Done" for exibido, as partições serão adicionadas com sucesso.

   Figura 3 Partições adicionadas
   
   

   • O número de partições só pode ser aumentado.
   • O número total de partições de todos os tópicos não pode exceder o número máximo de partições permitidas pela instância.

Método 3: usar a CLI do Kafka

Se a versão do seu cliente de Kafka for posterior a 2.2, você pode usar kafka-topics.sh para alterar a quantidade de partição.

Para uma instância com SASL habilitada, se allow.everyone.if.no.acl.found estiver definido como false, a quantidade de partição de tópico não poderá ser modificada por meio do cliente.

• Se a SASL não estiver habilitada para a instância do Kafka, execute o seguinte comando no diretório /{directory where the CLI is located}/kafka_{version}/bin/ para alterar a quantidade de partição:

  ./kafka-topics.sh --bootstrap-server {broker_ip}:{port} --topic {topic_name} --alter --partitions {partition_num}
• Se a SASL tiver sido habilitada para a instância do Kafka, execute as seguintes etapas para alterar a quantidade de partição:
  1. (Opcional) Se a configuração do certificado SSL tiver sido definida, ignore esta etapa. Caso contrário, execute as seguintes operações:

     Crie o arquivo ssl-user-config.properties no diretório /config do cliente de Kafka e adicione as configurações de certificado SSL consultando 3.

  2. Execute o seguinte comando no diretório /{directory where the CLI is located}/kafka_{version}/bin/ para alterar a quantidade de partição:

     ./kafka-topics.sh --bootstrap-server {broker_ip}:{port} --topic {topic_name} --alter --partitions {partition_num} --command-config ./config/ssl-user-config.properties