message.setPartitionId(PartitionId.from(partitionKey));
String path = HelixUtil.getMessagePath(clusterName, instanceName) + "/" + message.getId();
ObjectMapper mapper = new ObjectMapper();
StringWriter sw = new StringWriter();
mapper.writeValueUsingView(sw, message, Message.class);
System.out.println(sw.toString());
client.delete(path);
Thread.sleep(10000);
ZNRecord record = client.readData(HelixUtil.getLiveInstancePath(clusterName, instanceName));