Kafka indexing peons fail saying "The task was asked to stop before completing" frequently

[Akshay Jain]

Hey Everyone,

I am using 0.15.1-incubating

I am trying to run kafka indexing job.
I am observing that a lot of my tasks/peons fail in the end after logging -> "The task was asked to stop before completing."
There is no other error message or exception in the logs.
I randomly see "Failed to push merged index for segment" without any root cause details.

Can anyone help me understand possible reason of this ?
My kafka indexing starts lagging because of so many failures.

Regards,
Akshay