fix some params for consumer can not be changed

Author: cserwen

consumer/option.go

@@ -118,6 +118,7 @@ func defaultPushConsumerOptions() consumerOptions {
 		ConsumerModel:              Clustering,
 		AutoCommit:                 true,
 		Resolver:                   primitive.NewHttpResolver("DEFAULT"),
+		ConsumeTimestamp: 			time.Now().Add(time.Minute * (-30)).Format("20060102150405"),
 	}
 	opts.ClientOptions.GroupName = "DEFAULT_CONSUMER"
 	return opts
@@ -158,6 +159,24 @@ func WithConsumeMessageBatchMaxSize(consumeMessageBatchMaxSize int) Option {
 	}
 }
 
+func WithConsumeTimestamp(consumeTimestamp string) Option {
+	return func(options *consumerOptions) {
+		options.ConsumeTimestamp = consumeTimestamp
+	}
+}
+
+func WithConsumerPullTimeout(consumerPullTimeout time.Duration) Option {
+	return func(options *consumerOptions) {
+		options.ConsumerPullTimeout = consumerPullTimeout
+	}
+}
+
+func WithConsumeConcurrentlyMaxSpan(consumeConcurrentlyMaxSpan int) Option {
+	return func(options *consumerOptions) {
+		options.ConsumeConcurrentlyMaxSpan = consumeConcurrentlyMaxSpan
+	}
+}
+
 // WithChainConsumerInterceptor returns a ConsumerOption that specifies the chained interceptor for consumer.
 // The first interceptor will be the outer most, while the last interceptor will be the inner most wrapper
 // around the real call.