You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2019/06/25 04:01:23 UTC
[GitHub] [pulsar] wolfstudy edited a comment on issue #4589: In Go client
2.3.2, can't get re-delivered message after add AckTimeout in ConsumerOptions
wolfstudy edited a comment on issue #4589: In Go client 2.3.2, can't get re-delivered message after add AckTimeout in ConsumerOptions
URL: https://github.com/apache/pulsar/issues/4589#issuecomment-505272423
@stevenwangnarvar hello, I didn't find the problem with the code you provided above. The acktimeout you set is 60s. When the 60s arrives and the message has not been acked, it will be received again.
```
2019/06/25 11:54:05.623 c_client.go:68: [info] INFO | ConnectionPool:72 | Created connection for pulsar://localhost:6650
2019/06/25 11:54:05.626 c_client.go:68: [info] INFO | ClientConnection:314 | [127.0.0.1:51022 -> 127.0.0.1:6650] Connected to broker
2019/06/25 11:54:05.630 c_client.go:68: [info] INFO | HandlerBase:52 | [persistent://public/default/some_partition_topic, ] Getting connection from pool
2019/06/25 11:54:05.630 c_client.go:68: [info] INFO | ConnectionPool:72 | Created connection for pulsar://ranxiaolong:6650
2019/06/25 11:54:05.632 c_client.go:68: [info] INFO | ClientConnection:316 | [127.0.0.1:51024 -> 127.0.0.1:6650] Connected to broker through proxy. Logical broker: pulsar://ranxiaolong:6650
2019/06/25 11:54:05.635 c_client.go:68: [info] INFO | ProducerImpl:155 | [persistent://public/default/some_partition_topic, ] Created producer on broker [127.0.0.1:51024 -> 127.0.0.1:6650]
2019/06/25 11:54:05.635 c_client.go:68: [info] INFO | Client:88 | Subscribing on Topic :persistent://public/default/some_partition_topic
2019/06/25 11:54:05.636 c_client.go:68: [info] INFO | HandlerBase:52 | [persistent://public/default/some_partition_topic, subName, 0] Getting connection from pool
2019/06/25 11:54:05.639 c_client.go:68: [info] INFO | ConsumerImpl:170 | [persistent://public/default/some_partition_topic, subName, 0] Created consumer on broker [127.0.0.1:51024 -> 127.0.0.1:6650]
Tuesday, 25-Jun-19 11:54:05 CST consume message-0
Tuesday, 25-Jun-19 11:54:05 CST consume message-1
Tuesday, 25-Jun-19 11:54:05 CST consume message-2
Tuesday, 25-Jun-19 11:54:05 CST consume message-3
Tuesday, 25-Jun-19 11:54:05 CST consume message-4
2019/06/25 11:56:05.637 c_client.go:68: [info] INFO | UnAckedMessageTrackerEnabled:47 | [persistent://public/default/some_partition_topic, subName, 0] : 15 Messages were not acked within 60000 time
Tuesday, 25-Jun-19 11:56:05 CST consume message-0
Tuesday, 25-Jun-19 11:56:05 CST consume message-1
Tuesday, 25-Jun-19 11:56:05 CST consume message-2
Tuesday, 25-Jun-19 11:56:05 CST consume message-3
Tuesday, 25-Jun-19 11:56:05 CST consume message-4
```
If you have any other questions, please let me know.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services