From df98c8169702e15d9d4d5e18e6c9a1aaf1a418e0 Mon Sep 17 00:00:00 2001 From: Ivan Yurchenko Date: Sun, 31 May 2026 12:25:10 +0200 Subject: [PATCH] KAFKA-19193: throw ConfigException if rack is empty in rack-aware mode As a follow-up to comments in https://github.com/apache/kafka/pull/19850 --- .../kafka/clients/producer/internals/RecordAccumulator.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java b/clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java index b1eced17e4f25..fd1cae3d8e4cc 100644 --- a/clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java +++ b/clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java @@ -26,6 +26,7 @@ import org.apache.kafka.common.PartitionInfo; import org.apache.kafka.common.TopicPartition; import org.apache.kafka.common.compress.Compression; +import org.apache.kafka.common.config.ConfigException; import org.apache.kafka.common.header.Header; import org.apache.kafka.common.metrics.Metrics; import org.apache.kafka.common.record.TimestampType; @@ -1240,7 +1241,7 @@ public PartitionerConfig(boolean enableAdaptivePartitioning, long partitionAvail this.rack = rack; if (rackAware && Utils.isBlank(rack)) { - throw new IllegalArgumentException("client.rack must be provided if partitioner.rack.aware is enabled"); + throw new ConfigException("client.rack must be provided if partitioner.rack.aware is enabled"); } }