-
Notifications
You must be signed in to change notification settings - Fork 370
Open
Description
pulsar-client-go/pulsar/consumer_impl.go
Lines 147 to 178 in cc18590
| retryTopic := topicName + "-" + options.SubscriptionName + RetryTopicSuffix | |
| dlqTopic := topicName + "-" + options.SubscriptionName + DlqTopicSuffix | |
| oldRetryTopic := tn.Domain + "://" + tn.Namespace + "/" + options.SubscriptionName + RetryTopicSuffix | |
| oldDlqTopic := tn.Domain + "://" + tn.Namespace + "/" + options.SubscriptionName + DlqTopicSuffix | |
| if r, err := client.lookupService.GetPartitionedTopicMetadata(oldRetryTopic); err == nil && | |
| r != nil && | |
| r.Partitions > 0 { | |
| retryTopic = oldRetryTopic | |
| } | |
| if r, err := client.lookupService.GetPartitionedTopicMetadata(oldDlqTopic); err == nil && | |
| r != nil && | |
| r.Partitions > 0 { | |
| dlqTopic = oldDlqTopic | |
| } | |
| if options.DLQ == nil { | |
| options.DLQ = &DLQPolicy{ | |
| MaxDeliveries: MaxReconsumeTimes, | |
| DeadLetterTopic: dlqTopic, | |
| RetryLetterTopic: retryTopic, | |
| } | |
| } else { | |
| if options.DLQ.DeadLetterTopic == "" { | |
| options.DLQ.DeadLetterTopic = dlqTopic | |
| } | |
| if options.DLQ.RetryLetterTopic == "" { | |
| options.DLQ.RetryLetterTopic = retryTopic | |
| } | |
| } |
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels