From e293bc5900cc9558b41690d3b866e9a2c9a77c6b Mon Sep 17 00:00:00 2001 From: Parth Brahmbhatt Date: Thu, 19 Mar 2015 11:28:35 -0700 Subject: [PATCH] KAFKA-2032: Add validation for partition.assignment.strategy. --- .../src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java | 1 + 1 file changed, 1 insertion(+) diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java b/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java index 42c7219..84f2677 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java @@ -171,6 +171,7 @@ public class ConsumerConfig extends AbstractConfig { .define(PARTITION_ASSIGNMENT_STRATEGY_CONFIG, Type.STRING, "blah", + in("range", "roundrobin"), Importance.MEDIUM, PARTITION_ASSIGNMENT_STRATEGY_DOC) .define(METADATA_MAX_AGE_CONFIG, -- 1.9.3 (Apple Git-50)