saurabh18cs
Honored Contributor III
 
    .option('kafka.request.timeout.ms',150000)
    .option('kafka.session.timeout.ms'200000)
    .option('group.max.session.timeout.ms'7200000)
    .option('failOnDataLoss''true')
    .option('startingOffsets''latest')
    .option('fetchOffset.numRetries', 1)
    .option('maxOffsetsPerTrigger', 1000)
  )
 
my settings see if any option here can help you