The num.partitions parameter is a server/broker config but you are using it as
a client/producer parameter so it will not work and will be ignored.
http://stackoverflow.com/questions/22152269/how-to-specify-number-of-partitions-on-kafka-2-8
I assume the CLI command you are using is the administrative kafka-topics.sh
tool which talks directly to zookeeper and the Kafka brokers to create or
modify topics in the Kafka cluster. This will work to create a topic before you
start your producer app.
-hans
> On Mar 26, 2017, at 2:00 AM, Laxmi Narayan wrote:
>
> Hi ,
> Kafka not accepting number of partitions from config , while from CLI it is
> accepting.
>
> What am I missing here ?
>
>
> props.put("bootstrap.servers", kafkaConstants.Bootstrap_Servers);
> props.put("enable.auto.commit", kafkaConstants.Enable_Auto_Commit);
> props.put("auto.commit.interval.ms",
> kafkaConstants.Auto_Commit_Interval_Ms);
> props.put("session.timeout.ms", kafkaConstants.Session_Timeout_Ms);
> props.put("linger.ms", "1");
>
> props.put("key.deserializer", kafkaConstants.Key_Deserializer);
> props.put("value.deserializer", kafkaConstants.Value_Deserializer);
>
> props.put("key.serializer", kafkaConstants.Key_Serializer);
> props.put("value.serializer", kafkaConstants.Value_Serializer);
>
> props.put("partitioner.class", kafkaConstants.Partitioner_Class);
> props.put("num.partitions", 999);
> props.put("group.id", kafkaConstants.KafkaGroupId);
>
>
>
>
>
>
> Keep learning keep moving .
