Added the option to customize group ids in advance for Kafka Consumer sources.