public String getSource() {
    return (String) this.messageMap.get("source");
  }
@return The source that sent the coordinator message. This is a string
        defined by the sender.
samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java