code: public StreamParameters withCommitTimeout(int commitTimeout) {
          return new StreamParameters(batchLimit, streamLimit, batchFlushTimeout, streamTimeout, streamKeepAliveLimit, maxUncommittedEvents, commitTimeout);
      }
docs: Maximum amount of seconds that nakadi will be waiting for commit after sending a batch to a client.
  If the commit does not come within this timeout, nakadi will initialize stream termination, no
  new data will be sent. Partitions from this stream will be assigned to other streams.
  
  @param commitTimeout