public <ValueType> KinesisInputDescriptor<KV<String, ValueType>> getInputDescriptor(String streamId,
      Serde<ValueType> valueSerde) {
    return new KinesisInputDescriptor<>(streamId, valueSerde, this);
  }
Gets an {@link KinesisInputDescriptor} for the input stream of this system.
<p>
The message in the stream will have {@link String} keys and {@code ValueType} values.

@param streamId id of the input stream
@param valueSerde stream level serde for the values in the messages in the input stream
@param <ValueType> type of the value in the messages in this stream
@return an {@link KinesisInputDescriptor} for the Kinesis input stream
samza-aws/src/main/java/org/apache/samza/system/kinesis/descriptors/KinesisSystemDescriptor.java