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: [email protected] With regards, Apache Git Services
