Usando a API do cliente Java do Kafka de administração

Se você usar uma versão do cliente Kafka 0.11 ou posterior ou Kafka Streams versão 0.10.2.0 ou posterior, será possível usar APIs para criar e excluir tópicos. Colocamos algumas restrições nas configurações que são permitidas ao criar tópicos. Veja as configurações a seguir que você pode modificar.

cleanup.policy

Configure para delete (padrão), compact ou delete,compact.

retention.ms

O período de retenção padrão é de 24 horas. O mínimo é uma hora e o máximo é 30 dias. Especifique esse valor como múltiplos de horas.

No plano Corporativo, é possível configurar a retenção para qualquer valor.

retention.bytes

O tamanho máximo que uma partição (que consiste em segmentos de log) pode atingir antes que descartemos segmentos de log antigos para liberar espaço.

Apenas o plano Enterprise. Configure para qualquer valor maior que 10 MB.

segment.bytes

O tamanho do arquivo de segmento para o log.

Apenas o plano Enterprise. Configure qualquer valor maior que 100 kB.

segment.index.bytes

O tamanho do índice que mapeia deslocamentos para posições do arquivo.

Apenas o plano Enterprise. Configure para qualquer valor entre 100 kB e 1 GB.

segment.ms

O período após o qual Kafka força o log a rolar mesmo se o arquivo de segmento não estiver cheio.

Apenas o plano Enterprise. Configurar para qualquer valor entre 5 minutos e 30 dias.