zer0Id0l

Is there any fix available for "connection timeout limit" ? Apart from intercepting the logs and taking necessary action (as stated above)

Not exactly, but I tried setting everything to LATEST_OFFSET. ``` recoveryOffset: kafka.LATEST_OFFSET, startingOffset: kafka.LATEST_OFFSET, time: kafka.LATEST_OFFSET ``` Also tried adding `time: kafka.LATEST_OFFSET` in strategies. Sometimes it recovers but not everytime....

I am using 0.9.0. We cannot upgrade our clusters to 0.10.0 as of now. :(