Обсуждаемые логи это просто летящие куски текста. Кафка как лог это последовательность записанных блобов и соединяется с первым только что там что-то летит и здесь что-то летит. Возмущены!
Подскажите как принудительно скомпактить топик с cleanup.policy=compact. Помимо короткого retention.ms я так понимаю нужно еще log.segment.bytes задать. Но мне нужно зачистить сравнительно свежие сообщения. Можно ли размер сегмента задать в районе 100байт?