Made possible to limit the number of Kafka partitions to utilize for Kafka data integration.