muralibasani commented on code in PR #23986:
URL: https://github.com/apache/kafka/pull/23986#discussion_r4393801049
##########
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##########
@@ -126,7 +126,10 @@ public class ProducerConfig extends AbstractConfig {
/** <code>partitioner.rack.aware</code> */
public static final String PARTITIONER_RACK_AWARE_CONFIG =
"partitioner.rack.aware";
- private static final String PARTITIONER_RACK_AWARE_DOC = "Controls whether
the default partitioner is rack-aware. This has no effect when a custom
partitioner is used.";
+ private static final String PARTITIONER_RACK_AWARE_DOC = "Controls whether
the default partitioner is rack-aware. "
+ + "When enabled, the sticky partition is chosen from partitions
whose leader is in the same rack as <code>" +
CommonClientConfigs.CLIENT_RACK_CONFIG
+ + "</code>, which must be set. It only applies to records without
a key, or to all records when <code>" + PARTITIONER_IGNORE_KEYS_CONFIG +
"=true</code>. "
+ + "This has no effect when a custom partitioner is used.";
Review Comment:
I think if you set partitioner.class and rack.aware to true, but leave
client.rack unset, the producer fails at construction ? So "This has no effect
when a custom partitioner is used." may not be fully true ?
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
