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.