Dealt with the case PartitioningStrategy.getPartitionKey(obj) returns the original object as partition key.