consume stuck after seekByTiime

[xige-16]

Expected behavior

consume success after seekByTime

Actual behavior

After running the for loop a few times, step msg := <-consumer.Chan() will be blocked.

Steps to reproduce

func TestPulsarChannel2(t *testing.T) {
	Params.Init()
	c, err := pulsar.NewClient(pulsar.ClientOptions{URL: Params.PulsarAddress})
	assert.Nil(t, err)
	for i := 0; i < 100; i++ {
		channel := strconv.Itoa(rand.Int())

		p, err := c.CreateProducer(pulsar.ProducerOptions{Topic: channel})
		assert.Nil(t, err)
		ppm := &pulsar.ProducerMessage{Payload: []byte{1}, Properties: map[string]string{}}
		_, err = p.Send(context.TODO(), ppm)
		assert.Nil(t, err)

		p.Close()

		consumer, err := c.Subscribe(pulsar.ConsumerOptions{
			Topic:                       channel,
			SubscriptionName:            "test",
			Type:                        pulsar.KeyShared,
			SubscriptionInitialPosition: pulsar.SubscriptionPositionEarliest,
		})
		assert.Nil(t, err)
		consumer.SeekByTime(time.Unix(0, 0))
		msg := <-consumer.Chan()
		assert.EqualValues(t, []byte{1}, msg.Payload)

		consumer.Close()
	}
}

System configuration

Pulsar version: x.y

[cckellogg]

Which client version are you using?

[xige-16]

Which client version are you using?

v0.5.0

[cckellogg]

Do you see the same issue with v0.6.0?

[xige-16]

v 0.6.0 is ok