Huanli-Meng commented on a change in pull request #7175:
URL: https://github.com/apache/pulsar/pull/7175#discussion_r435714528
##########
File path: site2/docs/client-libraries-java.md
##########
@@ -608,6 +608,22 @@ consumer2 receives the follwoing information.
("key-4", "message-4-2")
```
+If batch enabled at the producer side, messages with different key may add to
a batch by default. The broker will dispatch the batch to the consumer, so the
default batch mechanism may break the Key_Shared subscription guaranteed
message distribution semantics. The producer need to use the `KeyBasedBatcher`.
Review comment:
```suggestion
If batching is enabled at the producer side, messages with different keys
are added to a batch by default. The broker will dispatch the batch to the
consumer, so the default batch mechanism may break the Key_Shared subscription
guaranteed message distribution semantics. The producer needs to use the
`KeyBasedBatcher`.
```
##########
File path: site2/docs/client-libraries-java.md
##########
@@ -608,6 +608,22 @@ consumer2 receives the follwoing information.
("key-4", "message-4-2")
```
+If batch enabled at the producer side, messages with different key may add to
a batch by default. The broker will dispatch the batch to the consumer, so the
default batch mechanism may break the Key_Shared subscription guaranteed
message distribution semantics. The producer need to use the `KeyBasedBatcher`.
+
+```java
+Producer producer = client.newProducer()
+ .topic("my-topic")
+ .batcherBuilder(BatcherBuilder.KEY_BASED)
+ .create();
+```
+Or the producer can disable the message batch mechanism.
Review comment:
```suggestion
Or the producer can disable batching.
```
----------------------------------------------------------------
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]
