Merge pull request #44 from mesosphere/0_8_2_2

Fix persistence IDs for update case

kafka-scheduler/src/main/java/org/apache/mesos/kafka/offer/PersistentOfferRequirementProvider.java

@@ -79,7 +79,12 @@ public OfferRequirement getUpdateOfferRequirement(String configName, TaskInfo ta
     String brokerName = taskInfo.getName();
     Integer brokerId = OfferUtils.nameToId(brokerName);
     String taskId = taskInfo.getTaskId().getValue();
+
     String persistenceId = OfferUtils.getPersistenceId(taskInfo);
+    if (persistenceId == null) {
+      persistenceId = UUID.randomUUID().toString();
+    }
+
     TaskInfo newTaskInfo = getTaskInfo(configName, config, persistenceId, brokerId, taskId);
 
     log.info("newTaskInfo: " + newTaskInfo);