public StreamParameters withCommitTimeout ( int commitTimeout ) { return new StreamParameters ( batchLimit , streamLimit , batchFlushTimeout , streamTimeout , streamKeepAliveLimit , maxUncommittedEvents , commitTimeout ) ; }
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 .