Eu sou bastante novo no kafka, então me perdoe se essa pergunta for trivial. Eu tenho uma configuração muito simples para fins de testes de temporização da seguinte maneira:

O computador A -> grava no tópico 1 (Broker) -> o computador B lê do tópico 1 O computador B -> grava a mensagem apenas ler no tópico 2 (Broker) -> o computador A lê o tópico 2

Agora estou enviando mensagens de aproximadamente 1.400 bytes em um loop infinito, preenchendo o espaço do meu pequeno broker muito rapidamente. Estou experimentando definir valores diferentes para log.retention.ms, log.retention.bytes, log.segment.bytes e log.segment.delete.delay.ms. Primeiro, defino todos os valores para o mínimo permitido, mas parecia que esse desempenho estava degradado; depois, defina-os para o máximo que meu broker poderia levar antes de ficar completamente cheio, mas novamente o desempenho diminui quando ocorre uma exclusão. Existe uma prática recomendada para definir esses valores para obter o atraso mínimo absoluto?

Obrigado pela ajuda!