RETRY and DLQ topic name bug fixed for partition topics

apache · Dec 16, 2022 · a3f58da · a3f58da
1 parent e7e703b
commit a3f58da
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar/consumer_test.go b/pulsar/consumer_test.go
@@ -1603,7 +1603,7 @@ func TestRLQMultiTopics(t *testing.T) {
 
 	// subscribe DLQ Topic
 	dlqConsumer, err := client.Subscribe(ConsumerOptions{
-		Topic:                       partitionTopic + "-" + subName + "-DLQ",
+		Topic:                       normalTopic + "-" + subName + "-DLQ",
 		SubscriptionName:            subName,
 		SubscriptionInitialPosition: SubscriptionPositionEarliest,
 	})