Сбой потока Кафки даже после установки `request.timeout.ms` - PullRequest
Новая
       5

Сбой потока Кафки даже после установки `request.timeout.ms`

0 голосов
/ 07 декабря 2018

Я использую поток kafka для агрегирования данных и записи в другую тему. Каждые несколько минут происходит сбой, за исключением следующих случаев. 

Exception in thread "kafka-audio_spins-StreamThread-1" 
org.apache.kafka.streams.errors.StreamsException: task [0_37] Abort sending 
since an error caught with a previous record (key 67 value 245676645 timestamp 
1544142387319) to topic kafka-stream-KSTREAM-AGGREGATE-STATE-STORE-0000000002- 
repartition due to Expiring 1 record(s) for kafka-audio_spins-stream-KSTREAM- 
AGGREGATE-STATE-STORE-0000000002-repartition-43: 153251 ms has passed since 
batch creation plus linger time
You can increase producer parameter `retries` and `retry.backoff.ms` to avoid 
this error.

Я попытался выполнить нижеприведенный конфиг, и он все еще не работает. Каково максимальное значениемы можем установить таймаут или любое другое решение? 

streamsConfiguration.put(StreamsConfig.REQUEST_TIMEOUT_MS_CONFIG, 100000);
...