fix kafka index task doesn't resume when recieve duplicate request

[QiuMM]

When the kafka index task recieve duplicate setEndOffsets request, it returns and doesn't call resume() , this will cause the task pausing forever.

[clintropolis]

I think I see what's going on here and that this makes sense, 👍

Is it a major hassle to add a test for this?

[jihoonson]

Hi @QiuMM, would you elaborate more on this case? When and how can it happen that a kafka task is paused for the same endOffsets twice or more?

[QiuMM]

@jihoonson I am not sure how it happen, I just observed one kafka index task pasuing forever and found log like this: Ignoring duplicate request, end offsets already set for sequences.

[jihoonson]

@QiuMM thanks. I guess it might happen if no data has been ingested since the first endOffsets update when the second pause & update endOffsets are requested. I just wanted to check that my guess is correct. The latest change looks good to me.

[clintropolis]

Thanks for adding a test, LGTM 👍