Я прочитал, что на брокерах есть конфигурация для настройки продолжительности хранения данных смещения с offset.retention.minutes
. Моя архитектура Kafka состоит из 3 ZK, 3 брокеров и 2 рабочих kafka connect. Настройка, которую я использую, поставляется с этим сообщением . Я установил эту конфигурацию на 10 минут, но эффекта нет, и все же у меня ошибка, потому что мой диск переполнен, и я предположил, что виноват __consumer_offset
.