kafka-topics --zookeeper <host:port> --create --topic <topic_name> --partitions <number_of_partitions> --replication-factor <replication_factor> Example - kafka-topics --zookeeper <localhost:80> --create --topic newTopic --partitions 5 --replication-factor 1