This is an automated email from the ASF dual-hosted git repository.
viktorsomogyi pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new fc18c47efd6 KAFKA-19193: add Javadoc for rack-aware params in
BuiltInPartitioner (#22432)
fc18c47efd6 is described below
commit fc18c47efd6f8d8d2de19d1f46e64c901d35a329
Author: Ivan Yurchenko <[email protected]>
AuthorDate: Wed Jun 24 10:11:27 2026 +0200
KAFKA-19193: add Javadoc for rack-aware params in BuiltInPartitioner
(#22432)
As a follow-up to comments in https://github.com/apache/kafka/pull/19850
Reviewers: Viktor Somogyi-Vass <[email protected]>
---
.../apache/kafka/clients/producer/internals/BuiltInPartitioner.java | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/clients/src/main/java/org/apache/kafka/clients/producer/internals/BuiltInPartitioner.java
b/clients/src/main/java/org/apache/kafka/clients/producer/internals/BuiltInPartitioner.java
index 21d715af662..280f01224dd 100644
---
a/clients/src/main/java/org/apache/kafka/clients/producer/internals/BuiltInPartitioner.java
+++
b/clients/src/main/java/org/apache/kafka/clients/producer/internals/BuiltInPartitioner.java
@@ -53,6 +53,9 @@ public class BuiltInPartitioner {
*
* @param topic The topic
* @param stickyBatchSize How much to produce to partition before switch
+ * @param rackAware Whether the partitioner is rack-aware,
+ * i.e. prioritizes partitions whose leaders are in the
same rack as the producer
+ * @param rack The rack of the producer (needed for the rack-aware mode)
*/
public BuiltInPartitioner(LogContext logContext, String topic, int
stickyBatchSize, boolean rackAware, String rack) {
this.log = logContext.logger(BuiltInPartitioner.class);