@Override
		public Message<?> resolvePartitionKey(T entity) {
			return MessageBuilder.withPayload(entity).build();
		}
A {@link org.springframework.data.hadoop.store.partition.PartitionKeyResolver} which simply creates a new {@link Message}
as a partition key using an passed in entity.
spring-xd-hadoop/src/main/java/org/springframework/xd/integration/hadoop/partition/MessagePartitionStrategy.java