[GitHub] [pulsar] afire007 edited a comment on issue #6712: Pulsar Go Client Producer 2.4.1, 2.4.2 does not round robin messages by default when sending messages to multi partitioned topics

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

afire007 edited a comment on issue #6712: Pulsar Go Client Producer 2.4.1, 2.4.2 does not round robin messages by default when sending messages to multi partitioned topics
URL: https://github.com/apache/pulsar/issues/6712#issuecomment-612936403
 
 
   @sijie We are not sending any message keys when producing to the partitioned topic.  Below is the configuration we are using when sending data to the broker.  This applies to both non-persistent and persistent topics
   
   ```
   client, err := pulsar.NewClient(pulsar.ClientOptions{
       		URL: pulsarBroker,
   		Authentication: tls_auth,
   		TLSTrustCertsFilePath: pulsarSslCACertFile,
   		TLSAllowInsecureConnection: TLSAllowInsecureConnection,
   		TLSValidateHostname : TLSValidateHostname,
   		MessageListenerThreads: 1,
   		IOThreads: 1,
   	})
   
   	producer, err := client.CreateProducer(pulsar.ProducerOptions{
   		Topic: pulsarTopic,
   		CompressionType: pulsar.LZ4,
   		BatchingMaxMessages: uint(10000),
   		Batching: true,
   		MaxPendingMessages: 10000,
   		MessageRoutingMode: pulsar.RoundRobinDistribution,
   		BlockIfQueueFull: true,
   		BatchingMaxPublishDelay: time.Duration(1)*time.Millisecond,
   	})
   ```
   
   ```
   //Send Message Sync to Broker
   msg := pulsar.ProducerMessage{
   			    Payload: metric, //Metric is a byte[]
   			}
   err := producer.Send(context.Background(), msg)
   ```
   

----------------------------------------------------------------
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


With regards,
Apache Git Services