apache / apache/pulsar-client-go
Failed to get last message id when reader try to read from last message id
- Dominant language
- Go
- Stars
- 745
- Forks
- 389
- Avg merge
- 3d 20h
- Merged PRs (30d)
- 3
Description
#### Expected behavior
Failed to get the last message-id should not appeared.
#### Actual behavior
Failed to get the last message-id for many times until everything seems good to go
```
time="2021-07-28T15:25:31+09:00" level=info msg="[Connecting to broker]" remote_addr="pulsar://localhost:6650"
time="2021-07-28T15:25:31+09:00" level=info msg="[TCP connection established]" local_addr="[::1]:65070" remote_addr="pulsar://localhost:6650"
time="2021-07-28T15:25:31+09:00" level=info msg="[Connection is ready]" local_addr="[::1]:65070" remote_addr="pulsar://localhost:6650"
time="2021-07-28T15:25:31+09:00" level=info msg="[Connected consumer]" consumerID=1 name= subscription=reader-piqzh topic=topic
time="2021-07-28T15:25:31+09:00" level=info msg="[Created consumer]" consumerID=1 name= subscription=reader-piqzh topic=topic
time="2021-07-28T15:25:31+09:00" level=info msg="Broker notification of Closed consumer: 1" local_addr="[::1]:65070" remote_addr="pulsar://localhost:6650"
time="2021-07-28T15:25:31+09:00" level=info msg="[Reconnecting to broker in 100ms]" consumerID=1 name= subscription=reader-piqzh topic=topic
time="2021-07-28T15:25:31+09:00" level=error msg="[Failed to get last message id]" consumerID=1 error="server error: MetadataError: Consumer not found" name= subscription=reader-piqzh topic=topic
time="2021-07-28T15:25:31+09:00" level=error msg="[Failed to get last message id from broker]" error="server error: MetadataError: Consumer not found" topic=topic
time="2021-07-28T15:25:31+09:00" level=error msg="[Failed to get last message id]" consumerID=1 error="server error: MetadataError: Consumer not found" name= subscription=reader-piqzh topic=topic
time="2021-07-28T15:25:31+09:00" level=error msg="[Failed to get last message id from broker]" error="server error: MetadataError: Consumer not found" topic=topic
time="2021-07-28T15:25:31+09:00" level=error msg="[Failed to get last message id]" consumerID=1 error="server error: MetadataError: Consumer not found" name= subscription=reader-piqzh topic=topic
time="2021-07-28T15:25:31+09:00" level=error msg="[Failed to get last message id from broker]" error="server error: MetadataError: Consumer not found" topic=topic
time="2021-07-28T15:25:31+09:00" level=error msg="[Failed to get last message id]" consumerID=1 error="server error: MetadataError: Consumer not found" name= subscription=reader-piqzh topic=topic
time="2021-07-28T15:25:31+09:00" level=error msg="[Failed to get last message id from broker]" error="server error: MetadataError: Consumer not found" topic=topic
time="2021-07-28T15:25:31+09:00" level=error msg="[Failed to get last message id]" consumerID=1 error="server error: MetadataError: Consumer not found" name= subscription=reader-piqzh topic=topic
time="2021-07-28T15:25:31+09:00" level=error msg="[Failed to get last message id from broker]" error="server error: MetadataError: Consumer not found" topic=topic
time="2021-07-28T15:25:31+09:00" level=error msg="[Failed to get last message id]" consumerID=1 error="server error: MetadataError: Consumer not found" name= subscription=reader-piqzh topic=topic
time="2021-07-28T15:25:31+09:00" level=error msg="[Failed to get last message id from broker]" error="server error: MetadataError: Consumer not found" topic=topic
time="2021-07-28T15:25:31+09:00" level=error msg="[Failed to get last message id]" consumerID=1 error="server error: MetadataError: Consumer not found" name= subscription=reader-piqzh topic=topic
time="2021-07-28T15:25:31+09:00" level=error msg="[Failed to get last message id from broker]" error="server error: MetadataError: Consumer not found" topic=topic
time="2021-07-28T15:25:31+09:00" level=info msg="[Connected consumer]" consumerID=1 name= subscription=reader-piqzh topic=topic
time="2021-07-28T15:25:31+09:00" level=info msg="[Reconnected consumer to broker]" consumerID=1 name= subscription=reader-piqzh topic=topic
```
#### Steps to reproduce
Step 1. startup pulsar standalone
Step 2. produce some messages to a topic
Step 3. try to get latest message via reader api
```
cl, err := pulsar.NewClient(pulsar.ClientOptions{
URL: url,
OperationTimeout: 10 * time.Second,
ConnectionTimeout: 10 * time.Second,
})
cl.Close()
reader, err := cl.CreateReader(pulsar.ReaderOptions{
Topic: topic,
StartMessageID: pulsar.LatestMessageID(),
StartMessageIDInclusive: true,
})
for reader.HasNext() {
msg, err := reader.Next(context.Background())
}()
```
#### System configuration
**Pulsar version**: 2.7.1
Contributor guide
Assessment
This issue has not been assessed yet.