public int getVersion() {
    return (Integer) this.keyArray[VERSION_INDEX];
  }
@return The protocol version that the message conforms to.
samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java