@Override
				public int compare(Partition partition1, Partition partition2) {
					return partition1.getId() - partition2.getId();
				}
Is responsible for managing the partition allocation between multiple instances of a Kafka source module
deployed in a stream.
As a {@link FactoryBean} it will return the partitions that the current module instance should listen to.
The partitions for the given topic would be extracted from Kafka unless an explicit partition list
is provided.
Partitions are allocated evenly based on the number of module instances.
Zero-count Kafka source modules are not supported.

@author Marius Bogoevici
@author Ilayaperumal Gopinathan
extensions/spring-xd-extension-kafka/src/main/java/org/springframework/integration/x/kafka/KafkaPartitionAllocator.java