работают как нужно
props.put(StreamsConfig.RETRIES_CONFIG, Integer.MAX_VALUE); // default: 0
props.put(StreamsConfig.RETRY_BACKOFF_MS_CONFIG, TimeUnit.SECONDS.toMillis(1L)); // default: 100ms
для продьюсера судя по доке оверрайд дефолта по ретраям нужно сетить отдельно
делаю вот так:
props.put(StreamsConfig.producerPrefix(StreamsConfig.RETRIES_CONFIG), Integer.MAX_VALUE); // default: 10
сам стрим примитивно простой
читаем с топика -> флетМап -> пишем во второй топик
вылетает 10 раз по топику куда пишет продьюсер и стопает стрим
org.apache.kafka.common.errors.TimeoutException: Expiring 5 record(s) for {TOPIC_NAME}: 30929 ms has passed since last append
баг или фича?
А конфиг точно применилсЯ? Там на старте приложения стримз выплёвывает полный конфиг всего
Обсуждают сегодня