Hello Marimuthu, Partitions are created at the moment the topic is created, however, you can also add more new partitions to a topic once have been created. There is not a possibility to create partitions dynamically (out-of-the-box) into a topic unless you create your own business logic and/or scripts to do that. Kafka offers some scripts to alter the topics, take a look to https://kafka.apache.org/documentation/#basic_ops_modify_topic. Maybe you can consider using internal Kafka API Admin to do that as well ( https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java )
Beware that once the new partitions are created, maybe you will need to distribute them accordingly, take a look to https://kafka.apache.org/documentation/#basic_ops_partitionassignment Hope this helps, -- Jonathan On Tue, Jan 8, 2019 at 10:04 AM marimuthu eee <marimuthuee...@gmail.com> wrote: > Hi, > > My requirement is to process notification messages in parallel.So i have an > idea to pick kafka as a messaging system.But i need dynamic partitioning to > handle individual user notification messages.Is it possible to create > dynamic partition creation for a particular topic. > -- Santilli Jonathan
