Closed
Kafka TimeoutExceptions - Timeout of 60000ms expired before the position for partition PYSASBATCHINDEXCLASSESPROCESSOR
What additional configuration needed?
We installed Pega as AKS in Azure environment. During the import of the application, we are encountering Exception:
Caused by: com.pega.fnx.stream.spi.StreamServiceException: Stream SPI error at com.pega.fnx.stream.spi.impl.processor.StreamServiceExceptions.translateKafkaException(StreamServiceExceptions.java:62) ~[?:?] at com.pega.fnx.stream.spi.impl.processor.StreamServiceExceptions.translate(StreamServiceExceptions.java:40) ~[?:?] at com.pega.fnx.stream.spi.impl.processor.StreamServiceExceptions.translate(StreamServiceExceptions.java:31) ~[?:?] at com.pega.fnx.stream.spi.impl.processor.GetStartingOffsetsRequestProcessor.execute(GetStartingOffsetsRequestProcessor.java:69) ~[?:?] at com.pega.fnx.stream.spi.impl.processor.GetStartingOffsetsRequestProcessor.execute(GetStartingOffsetsRequestProcessor.java:34) ~[?:?] at com.pega.fnx.stream.spi.impl.StreamSPNative.execute(StreamSPNative.java:61) ~[?:?] ... 34 more Caused by: org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired before the position for partition PYSASBATCHINDEXCLASSESPROCESSOR-16 could be determined 2020-12-12 02:50:04,287 [itions=[10,11,12,13]] [ STANDARD] [ ] [ ] (w.listener.RetryLoggerListener) ERROR - [pySASBatchIndexClassesProcessor] Preparing retry 100. Next attempt in 2m on data flow [pySASBatchIndexClassesProcessor] on stage [InputStage] with affected partitions: [10, 11, 12, 13]