public <ValueType> EventHubsInputDescriptor<KV<String, ValueType>> getInputDescriptor(String streamId, String namespace,
      String entityPath, Serde<ValueType> valueSerde) {
    streamIds.add(streamId);
    return new EventHubsInputDescriptor<>(streamId, namespace, entityPath, valueSerde, this);
  }
Gets an {@link EventHubsInputDescriptor} for the input stream of this system. The stream has the provided
namespace and entity name of the associated Event Hubs entity and the provided stream level value serde.
<p>
The message in the stream will have {@link String} keys and {@code ValueType} values.

@param streamId id of the input stream
@param namespace namespace of the Event Hubs entity to consume from
@param entityPath entity path of the Event Hubs entity to consume from
@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 EventHubsInputDescriptor} for the Event Hubs input stream
samza-azure/src/main/java/org/apache/samza/system/eventhub/descriptors/EventHubsSystemDescriptor.java