public KafkaInputDescriptor<StreamMessageType> withConsumerFetchMessageMaxBytes(long fetchMessageMaxBytes) {
    this.consumerFetchMessageMaxBytesOptional = Optional.of(fetchMessageMaxBytes);
    return this;
  }
The number of bytes of messages to attempt to fetch for each topic-partition for this topic in each fetch request.
These bytes will be read into memory for each partition, so this helps control the memory used by the consumer.
The fetch request size must be at least as large as the maximum message size the server allows or else it is
possible for the producer to send messages larger than the consumer can fetch.
<p>
Note: This property may be set at a system level using {@link KafkaSystemDescriptor#withConsumerFetchMessageMaxBytes}

@param fetchMessageMaxBytes number of bytes of messages to attempt to fetch for each topic-partition
                            in each fetch request
@return this input descriptor
samza-kafka/src/main/java/org/apache/samza/system/kafka/descriptors/KafkaInputDescriptor.java