ZeroQueueConsumer is not supported with RetryEnable (#1391)

Author: crossoverJie

pulsar/consumer_impl.go

@@ -74,6 +74,11 @@ type consumer struct {
 }
 
 func newConsumer(client *client, options ConsumerOptions) (Consumer, error) {
+
+	if options.RetryEnable && options.EnableZeroQueueConsumer {
+		return nil, newError(InvalidConfiguration, "ZeroQueueConsumer is not supported with RetryEnable")
+	}
+
 	if options.Topic == "" && options.Topics == nil && options.TopicsPattern == "" {
 		return nil, newError(TopicNotFound, "topic is required")
 	}

pulsar/consumer_zero_queue_test.go

@@ -31,6 +31,26 @@ import (
 	"github.com/stretchr/testify/assert"
 )
 
+func TestRetryEnableZeroQueueConsumer(t *testing.T) {
+	client, err := NewClient(ClientOptions{
+		URL: lookupURL,
+	})
+
+	assert.Nil(t, err)
+	defer client.Close()
+
+	topic := newTopicName()
+
+	// create consumer
+	_, err = client.Subscribe(ConsumerOptions{
+		Topic:                   topic,
+		SubscriptionName:        "my-sub",
+		RetryEnable:             true,
+		EnableZeroQueueConsumer: true,
+	})
+	assert.ErrorContains(t, err, "ZeroQueueConsumer is not supported with RetryEnable")
+}
+
 func TestNormalZeroQueueConsumer(t *testing.T) {
 	client, err := NewClient(ClientOptions{
 		URL: lookupURL,