Política óptima de retención y eliminación de Kafka

Soy bastante nuevo en kafka, así que perdóname si esta pregunta es trivial. Tengo una configuración muy simple para propósitos de pruebas de tiempo como sigue:

Máquina A -> escribe en el tema 1 (Intermediario) -> Máquina B lee del tema 1 Máquina B -> escribe el mensaje que acaba de leer en el tema 2 (Intermediario) -> Máquina A lee del tema 2

Ahora estoy enviando mensajes de aproximadamente 1400 bytes en un bucle infinito llenando el espacio en mi pequeño corredor muy rápidamente. Estoy experimentando con el establecimiento de diferentes valores para log.retention.ms, log.retention.bytes, log.segment.bytes y log.segment.delete.delay.ms. Primero configuré todos los valores al mínimo permitido, pero parecía que este rendimiento disminuía, luego los configuré al máximo que mi corredor podría tomar antes de estar completamente lleno, pero nuevamente el rendimiento se degrada cuando se produce una eliminación. ¿Existe alguna práctica recomendada para establecer estos valores para obtener el retraso mínimo absoluto?

¡Gracias por la ayuda!

Respuestas a la pregunta(1)

Su respuesta a la pregunta