From e935a4b27bad0836616cc8df15836ac5674366c9 Mon Sep 17 00:00:00 2001 From: boncheff Date: Mon, 28 Oct 2019 17:30:46 +0000 Subject: [PATCH] Update client-libraries-go.md (#5382) (cherry picked from commit cfef0fb488f197436d3da34dbc8e5d98892d1d8f) --- site2/docs/client-libraries-go.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/site2/docs/client-libraries-go.md b/site2/docs/client-libraries-go.md index c9bb8a87fb5..53b5a664ca8 100644 --- a/site2/docs/client-libraries-go.md +++ b/site2/docs/client-libraries-go.md @@ -292,7 +292,7 @@ func main() { consumer, err := client.Subscribe(pulsar.ConsumerOptions{ Topic: "my-golang-topic", SubscriptionName: "sub-1", - SubscriptionType: pulsar.Exclusive, + Type: pulsar.Exclusive, }) if err != nil { log.Fatal(err) } @@ -329,7 +329,7 @@ Parameter | Description | Default `Name` | The name of the consumer | `AckTimeout` | | 0 `NackRedeliveryDelay` | The delay after which to redeliver the messages that failed to be processed. Default is 1min. (See `Consumer.Nack()`) | 1 minute -`SubscriptionType` | Available options are `Exclusive`, `Shared`, and `Failover` | `Exclusive` +`Type` | Available options are `Exclusive`, `Shared`, and `Failover` | `Exclusive` `MessageChannel` | The Go channel used by the consumer. Messages that arrive from the Pulsar topic(s) will be passed to this channel. | `ReceiverQueueSize` | Sets the size of the consumer's receiver queue, i.e. the number of messages that can be accumulated by the consumer before the application calls `Receive`. A value higher than the default of 1000 could increase consumer throughput, though at the expense of more memory utilization. | 1000 `MaxTotalReceiverQueueSizeAcrossPartitions` |Set the max total receiver queue size across partitions. This setting will be used to reduce the receiver queue size for individual partitions if the total exceeds this value | 50000 -- GitLab