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 2021/09/10 11:35:09 UTC
[GitHub] [pulsar-client-go] 9ft opened a new issue #615: Consume retry not work on specified-partition topic
9ft opened a new issue #615:
URL: https://github.com/apache/pulsar-client-go/issues/615
#### Expected behavior
The `ReconsumeLater()` message should be written to retry topic.
#### Actual behavior
Retry did not work when subscribing to a topic that specified partition.
Error shows:
```
time="2021-09-10T11:09:39Z" level=warning msg="consumer of topic persistent://public/default/mytopic-partition-0 not exist unexpectedly" topic="[persistent://public/default/mytopic-partition-0 persistent://public/default/sub01-RETRY]"
```
#### Steps to reproduce
1. Consume a topic that specified partition.
For example, `persistent://public/default/mytopic-partition-0`
3. `ReconsumeLater()` on consume message.
4. Will not receive any retry messages.
#### System configuration
**Pulsar version**: x.y
--
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.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar-client-go] cckellogg commented on issue #615: Consume retry not work on specified-partition topic
Posted by GitBox <gi...@apache.org>.
cckellogg commented on issue #615:
URL: https://github.com/apache/pulsar-client-go/issues/615#issuecomment-917282803
That kind of seems like a misuse of the api? Curious to when you would only want to subscribe to a single partition? If this `persistent://public/default/mytopic` is passed in does the issue go away?
--
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.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar-client-go] 9ft commented on issue #615: Consume retry not work on specified-partition topic
Posted by GitBox <gi...@apache.org>.
9ft commented on issue #615:
URL: https://github.com/apache/pulsar-client-go/issues/615#issuecomment-917157047
@cckellogg Subscribe specified-partition topic for example persistent://public/default/mytopic-partition-0 will cause the problem.
```go
rlqConsumer, err := client.Subscribe(ConsumerOptions{
Topic: "persistent://public/default/mytopic-partition-0",
SubscriptionName: "sub01",
Type: Shared,
SubscriptionInitialPosition: SubscriptionPositionEarliest,
DLQ: &DLQPolicy{MaxDeliveries: 2},
RetryEnable: true,
NackRedeliveryDelay: 1 * time.Second,
})
```
--
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.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar-client-go] wolfstudy closed issue #615: Consume retry not work on specified-partition topic
Posted by GitBox <gi...@apache.org>.
wolfstudy closed issue #615:
URL: https://github.com/apache/pulsar-client-go/issues/615
--
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.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar-client-go] 9ft commented on issue #615: Consume retry not work on specified-partition topic
Posted by GitBox <gi...@apache.org>.
9ft commented on issue #615:
URL: https://github.com/apache/pulsar-client-go/issues/615#issuecomment-917448814
> That kind of seems like a misuse of the api? Curious to when you would only want to subscribe to a single partition? If this `persistent://public/default/mytopic` is passed in does the issue go away?
Thanks for the review, I don't think this is a misuse.
Producers can route messages to a given partition via `MessageRouter()` option.
Naturally will want to consume the data from the partition separately.
In my case is to control consume rate for different kinds of messages. Other case such as
https://github.com/apache/pulsar/issues/3098
--
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.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar-client-go] cckellogg commented on issue #615: Consume retry not work on specified-partition topic
Posted by GitBox <gi...@apache.org>.
cckellogg commented on issue #615:
URL: https://github.com/apache/pulsar-client-go/issues/615#issuecomment-917150612
What topics did with the consumer options?
--
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.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar-client-go] 9ft edited a comment on issue #615: Consume retry not work on specified-partition topic
Posted by GitBox <gi...@apache.org>.
9ft edited a comment on issue #615:
URL: https://github.com/apache/pulsar-client-go/issues/615#issuecomment-917157047
@cckellogg Subscribe specified-partition topic for example `persistent://public/default/mytopic-partition-0` will cause the problem.
```go
rlqConsumer, err := client.Subscribe(ConsumerOptions{
Topic: "persistent://public/default/mytopic-partition-0",
SubscriptionName: "sub01",
Type: Shared,
SubscriptionInitialPosition: SubscriptionPositionEarliest,
DLQ: &DLQPolicy{MaxDeliveries: 2},
RetryEnable: true,
NackRedeliveryDelay: 1 * time.Second,
})
```
--
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.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar-client-go] 9ft commented on issue #615: Consume retry not work on specified-partition topic
Posted by GitBox <gi...@apache.org>.
9ft commented on issue #615:
URL: https://github.com/apache/pulsar-client-go/issues/615#issuecomment-917450213
@cckellogg Please review the new commit, using a simpler way to handle it.
--
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.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org