improve: use ctx and timer instead sleep

[nodece]

Motivation

We are using time.Sleep and for to execute the retry, which cannot be interrupted, this PR will use context and timer to improve this behavior.

The next improvement idea supports passing the context to interrupt the retry, when closing the producer or consumer, we need to do that.

Modifications

• Add the Retry method to execute the try, and use Retry instead of time.Sleep and for.

[nodece]

Let me fix the consumer seek test first.

[nodece]

Seek test will be fixed by #1265.

[nodece]

@RobertIndie @crossoverJie Could you have a chance to review?