[GitHub] [pulsar-client-go] wolfstudy commented on issue #267: Is there any relationship between consumer throughput and ConsumerOptions.ReceiverQueueSize and ConsumerOptions.MessageChannel and the time required to process each message?

[GitBox <gi...@apache.org>]

wolfstudy commented on issue #267:
URL: https://github.com/apache/pulsar-client-go/issues/267#issuecomment-639340257


   The `MessageChannel` is used to receive messages, all messages received by consumers will be filled into MessageChannel, the code example as follows:
   
   ```
   channel := make(chan pulsar.ConsumerMessage, 100)
   
   	options := pulsar.ConsumerOptions{
   		Topic:            "topic-1",
   		SubscriptionName: "my-subscription",
   		Type:             pulsar.Shared,
   	}
   
   	options.MessageChannel = channel
   
   	consumer, err := client.Subscribe(options)
   	if err != nil {
   		log.Fatal(err)
   	}
   
   	defer consumer.Close()
   
   	// Receive messages from channel. The channel returns a struct which contains message and the consumer from where
   	// the message was received. It's not necessary here since we have 1 single consumer, but the channel could be
   	// shared across multiple consumers as well
   	for cm := range channel {
   		msg := cm.Message
   		fmt.Printf("Received message  msgId: %v -- content: '%s'\n",
   			msg.ID(), string(msg.Payload()))
   
   		consumer.Ack(msg)
   	}
   ```
   
   The `ReceiverQueueSize` sets the size of the consumer to receive queue. It is a buffer of a channel in go language. Default value is 1000


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org