kafka is not accepting number of partitions from configuration

[Laxmi Narayan]

​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 .....