Kafka TimeoutExceptions - Timeout of 60000ms expired before the position for partition PYSASBATCHINDEXCLASSESPROCESSOR

General
, ,
1

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] 
2

Hi @Ramonm02

Any luck resolving the issue? I am also facing the similar issue.