public Serde getKeySerde() {
    return keySerde;
  }
Get the key serde for this input stream if any.

@return the key serde if any, else null
samza-core/src/main/java/org/apache/samza/operators/spec/InputOperatorSpec.java