Re: kafka is not accepting number of partitions from configuration

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

kafka is not accepting number of partitions from configuration

​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);